public class TierTopicReaderConfig extends Object
Constructor and Description |
---|
TierTopicReaderConfig(Supplier<Map<String,Object>> interBrokerClientConfigs,
String clusterId,
int brokerId,
int tierMetadataNumPartitions,
long tierMetadataMaxPollMs,
List<Long> tierOffsets,
Long maxDeleteCompleteRecordsToConsumeInOneIteration,
Consumer<Long> recordLag,
Supplier<Boolean> canCLMRun,
Supplier<Boolean> isShutdownInitiated,
org.apache.kafka.common.utils.Time time,
int maxRetries,
Supplier<Integer> maxLookBackInDays) |
public TierTopicReaderConfig(Supplier<Map<String,Object>> interBrokerClientConfigs, String clusterId, int brokerId, int tierMetadataNumPartitions, long tierMetadataMaxPollMs, List<Long> tierOffsets, Long maxDeleteCompleteRecordsToConsumeInOneIteration, Consumer<Long> recordLag, Supplier<Boolean> canCLMRun, Supplier<Boolean> isShutdownInitiated, org.apache.kafka.common.utils.Time time, int maxRetries, Supplier<Integer> maxLookBackInDays)