luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Log changes

Browse source
This commit is contained in:
Ashwin Giridharan 2020-06-22 23:37:38 -07:00
parent d4f3c0b14a
commit ef39ecd0df
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
View file

@ -231,8 +231,8 @@ public class PrefetchRecordsPublisher implements RecordsPublisher {
throw new IllegalStateException("ExecutorService has been shutdown."); throw new IllegalStateException("ExecutorService has been shutdown.");
} }
if (!started) { if (!started) {
log.info("{} : Starting Prefetching thread and initializing publisher session.", streamAndShardId);
publisherSession.init(extendedSequenceNumber, initialPositionInStreamExtended); publisherSession.init(extendedSequenceNumber, initialPositionInStreamExtended);
log.info("{} : Starting prefetching thread and initializing publisher session.", streamAndShardId);
executorService.execute(defaultGetRecordsCacheDaemon); executorService.execute(defaultGetRecordsCacheDaemon);
} else { } else {
log.info("{} : Skipping publisher start as it was already started.", streamAndShardId); log.info("{} : Skipping publisher start as it was already started.", streamAndShardId);