@Internal public class PollingRecordPublisherConfiguration extends Object
PollingRecordPublisher
instantiated from a properties map.Constructor and Description |
---|
PollingRecordPublisherConfiguration(Properties consumerConfig) |
Modifier and Type | Method and Description |
---|---|
long |
getFetchIntervalMillis() |
int |
getMaxNumberOfRecordsPerFetch() |
boolean |
isAdaptiveReads() |
public PollingRecordPublisherConfiguration(Properties consumerConfig)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.