From 118a0eb0e5e482706c0fcc435604b9351922811d Mon Sep 17 00:00:00 2001 From: Oguzhan Unlu Date: Thu, 10 Oct 2024 16:57:31 +0300 Subject: [PATCH] fmt --- shard_consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/shard_consumer.go b/shard_consumer.go index b018b29..e4fd256 100644 --- a/shard_consumer.go +++ b/shard_consumer.go @@ -81,7 +81,7 @@ func (k *Kinsumer) getRecords(kApi kinesisiface.KinesisAPI, streamName string, s return nil, "", 0, err } - fmt.Printf("seq num for shard [id: %s]: %s", shardID, seqNum) + fmt.Printf("seq num for shard [id: %s]: %s\n", shardID, seqNum) it, ierr := getShardIterator(kApi, streamName, shardID, seqNum, nil) if ierr != nil {