Compare commits

...

1 commit

Author SHA1 Message Date
Ryan Pelaez
d5b44acd09 removed unused argument idleTimeInMilliseconds 2025-02-04 13:26:09 -08:00
3 changed files with 0 additions and 5 deletions

View file

@ -263,7 +263,6 @@ class ConsumerStates {
throttlingReporter,
input,
argument.shouldCallProcessRecordsEvenForEmptyRecordList(),
argument.idleTimeInMilliseconds(),
argument.aggregatorUtil(),
argument.metricsFactory(),
argument.schemaRegistryDecoder(),

View file

@ -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;

View file

@ -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;