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

Added debug logs in KinesisLocalFileDataCreator

Browse source
This commit is contained in:
parijas 2018-01-09 14:51:33 -08:00
parent f15c0fd8e0
commit 1ff00d0b01
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java
View file

@ -119,7 +119,9 @@ public class KinesisLocalFileDataCreator {
maxSequenceNumber = new BigInteger(endingSequenceNumber); maxSequenceNumber = new BigInteger(endingSequenceNumber);
} }
if (maxSequenceNumber.compareTo(sequenceNumber) != 1) { if (maxSequenceNumber.compareTo(sequenceNumber) != 1) {
throw new IllegalArgumentException("Not enough space in shard"); throw new IllegalArgumentException("Not enough space in shard. maxSequenceNumber: "
+ maxSequenceNumber.toString() + ", sequenceNumber: " + sequenceNumber.toString()
+ ", sequenceNumberIncrement: " + sequenceNumberIncrement.toString());
} }
String partitionKey = String partitionKey =
PARTITION_KEY_PREFIX + shard.getShardId() + generateRandomString(PARTITION_KEY_LENGTH); PARTITION_KEY_PREFIX + shard.getShardId() + generateRandomString(PARTITION_KEY_LENGTH);