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

Removing unnecessary log statement.

Browse source
This commit is contained in:
Sahil Palvia 2018-04-17 15:40:08 -07:00
parent 5030b81564
commit c63d62b8db
1 changed files with 0 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/RecordProcessorCheckpointer.java
View file

@ -113,10 +113,6 @@ public class RecordProcessorCheckpointer implements IRecordProcessorCheckpointer
+ subSequenceNumber);
}
if (log.isDebugEnabled()) {
log.debug("Validated checkpoint sequence number {} for {}, token {}", sequenceNumber,
shardInfo.shardId(), shardInfo.concurrencyToken());
}
/*
* If there isn't a last checkpoint value, we only care about checking the upper bound.
* If there is a last checkpoint value, we want to check both the lower and upper bound.
@ -186,10 +182,6 @@ public class RecordProcessorCheckpointer implements IRecordProcessorCheckpointer
+ subSequenceNumber);
}
if (log.isDebugEnabled()) {
log.debug("Validated prepareCheckpoint sequence number {} for {}, token {}", sequenceNumber,
shardInfo.shardId(), shardInfo.concurrencyToken());
}
/*
* If there isn't a last checkpoint value, we only care about checking the upper bound.
* If there is a last checkpoint value, we want to check both the lower and upper bound.