Skip to content

Commit 0cd4edb

Browse files
author
ebartkus
committed
enable "IgnoreUnexpectedChildShards" option
To fix issue awslabs/amazon-kinesis-client#164
1 parent 8fd6906 commit 0cd4edb

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

source/src/main/java/com/trustpilot/connector/dynamodb/kcl/KclWorkerImpl.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,10 @@ KinesisClientLibConfiguration getClientLibConfiguration(String tableName,
156156
.withFailoverTimeMillis(Constants.KCL_FAILOVER_TIME)
157157

158158
// logs warning if RecordProcessor task is blocked for long time periods.
159-
.withLogWarningForTaskAfterMillis(60 * 1000);
159+
.withLogWarningForTaskAfterMillis(60 * 1000)
160+
161+
// fix some random issues with https://github.com/awslabs/amazon-kinesis-client/issues/164
162+
.withIgnoreUnexpectedChildShards(true);
160163
}
161164

162165
/**

0 commit comments

Comments
 (0)