From 1ff00d0b01d6d95a02b7ae67e542977a75b6e307 Mon Sep 17 00:00:00 2001 From: parijas Date: Tue, 9 Jan 2018 14:51:33 -0800 Subject: [PATCH] Added debug logs in KinesisLocalFileDataCreator --- .../proxies/util/KinesisLocalFileDataCreator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java b/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java index e5e4419a..93e80d4e 100644 --- a/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java +++ b/src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java @@ -119,7 +119,9 @@ public class KinesisLocalFileDataCreator { maxSequenceNumber = new BigInteger(endingSequenceNumber); } 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 = PARTITION_KEY_PREFIX + shard.getShardId() + generateRandomString(PARTITION_KEY_LENGTH);