diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java index eb1a8f48..bced2952 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java @@ -263,7 +263,6 @@ class ConsumerStates { throttlingReporter, input, argument.shouldCallProcessRecordsEvenForEmptyRecordList(), - argument.idleTimeInMilliseconds(), argument.aggregatorUtil(), argument.metricsFactory(), argument.schemaRegistryDecoder(), diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java index 34543cc4..29e7cfa3 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java @@ -60,7 +60,6 @@ public class ProcessTask implements ConsumerTask { private final Shard shard; private final ThrottlingReporter throttlingReporter; private final boolean shouldCallProcessRecordsEvenForEmptyRecordList; - private final long idleTimeInMilliseconds; private final ProcessRecordsInput processRecordsInput; private final MetricsFactory metricsFactory; private final AggregatorUtil aggregatorUtil; @@ -78,7 +77,6 @@ public class ProcessTask implements ConsumerTask { @NonNull ThrottlingReporter throttlingReporter, ProcessRecordsInput processRecordsInput, boolean shouldCallProcessRecordsEvenForEmptyRecordList, - long idleTimeInMilliseconds, @NonNull AggregatorUtil aggregatorUtil, @NonNull MetricsFactory metricsFactory, SchemaRegistryDecoder schemaRegistryDecoder, @@ -91,7 +89,6 @@ public class ProcessTask implements ConsumerTask { this.throttlingReporter = throttlingReporter; this.processRecordsInput = processRecordsInput; this.shouldCallProcessRecordsEvenForEmptyRecordList = shouldCallProcessRecordsEvenForEmptyRecordList; - this.idleTimeInMilliseconds = idleTimeInMilliseconds; this.metricsFactory = metricsFactory; this.schemaRegistryDecoder = schemaRegistryDecoder; this.leaseStatsRecorder = leaseStatsRecorder; diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerArgument.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerArgument.java index bc1b9d20..7ce64bd4 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerArgument.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerArgument.java @@ -70,7 +70,6 @@ public class ShardConsumerArgument { private final long listShardsBackoffTimeInMillis; private final int maxListShardsRetryAttempts; private final boolean shouldCallProcessRecordsEvenForEmptyRecordList; - private final long idleTimeInMilliseconds; @NonNull private final InitialPositionInStreamExtended initialPositionInStream;