Spring/spring-integration-aws
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-146 log sequenceNumber when consumer starts

Browse Source
This commit is contained in:
Sergiu Pantiru
2019-05-23 13:14:03 +02:00
committed by Artem Bilan
parent 83a588c5ab
commit e6e2465846
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
View File

@@ -825,9 +825,6 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
case EXPIRED:
this.task = () -> {
try {
if (logger.isInfoEnabled() && this.state == ConsumerState.NEW) {
logger.info("The [" + this + "] has been started.");
}
if (this.shardOffset.isReset()) {
this.checkpointer.remove();
}
@@ -838,7 +835,9 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
this.shardOffset.setIteratorType(ShardIteratorType.AFTER_SEQUENCE_NUMBER);
}
}
if (logger.isInfoEnabled() && this.state == ConsumerState.NEW) {
logger.info("The [" + this + "] has been started.");
}
GetShardIteratorRequest shardIteratorRequest = this.shardOffset.toShardIteratorRequest();
this.shardIterator =
KinesisMessageDrivenChannelAdapter.this.amazonKinesis