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 {