public class ConsumerConfig extends AbstractConfig
Modifier | Constructor and Description |
---|---|
protected |
ConsumerConfig(Map<?,?> props,
boolean doLog) |
|
ConsumerConfig(Map<String,Object> props) |
|
ConsumerConfig(Properties props) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
addDeserializerToConfig(Map<String,Object> configs,
Deserializer<?> keyDeserializer,
Deserializer<?> valueDeserializer) |
static Properties |
addDeserializerToConfig(Properties properties,
Deserializer<?> keyDeserializer,
Deserializer<?> valueDeserializer) |
static ConfigDef |
configDef() |
static Set<String> |
configNames() |
static void |
main(String[] args) |
protected Map<String,Object> |
postProcessParsedConfig(Map<String,Object> parsedValues)
Called directly after user configs got parsed (and thus default values got set).
|
equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String GROUP_ID_CONFIG
group.id
public static final String GROUP_INSTANCE_ID_CONFIG
group.instance.id
public static final String MAX_POLL_RECORDS_CONFIG
max.poll.records
public static final String MAX_POLL_INTERVAL_MS_CONFIG
max.poll.interval.ms
public static final String SESSION_TIMEOUT_MS_CONFIG
session.timeout.ms
public static final String HEARTBEAT_INTERVAL_MS_CONFIG
heartbeat.interval.ms
public static final String BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
public static final String CLIENT_DNS_LOOKUP_CONFIG
client.dns.lookup
public static final String ENABLE_AUTO_COMMIT_CONFIG
enable.auto.commit
public static final String AUTO_COMMIT_INTERVAL_MS_CONFIG
auto.commit.interval.ms
public static final String PARTITION_ASSIGNMENT_STRATEGY_CONFIG
partition.assignment.strategy
public static final String AUTO_OFFSET_RESET_CONFIG
auto.offset.reset
public static final String AUTO_OFFSET_RESET_DOC
public static final String FETCH_MIN_BYTES_CONFIG
fetch.min.bytes
public static final String FETCH_MAX_BYTES_CONFIG
fetch.max.bytes
public static final int DEFAULT_FETCH_MAX_BYTES
public static final String FETCH_MAX_WAIT_MS_CONFIG
fetch.max.wait.ms
public static final String METADATA_MAX_AGE_CONFIG
metadata.max.age.ms
public static final String MAX_PARTITION_FETCH_BYTES_CONFIG
max.partition.fetch.bytes
public static final int DEFAULT_MAX_PARTITION_FETCH_BYTES
public static final String SEND_BUFFER_CONFIG
send.buffer.bytes
public static final String RECEIVE_BUFFER_CONFIG
receive.buffer.bytes
public static final String CLIENT_ID_CONFIG
client.id
public static final String CLIENT_RACK_CONFIG
client.rack
public static final String RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
public static final String RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms
public static final String RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms
public static final String METRICS_SAMPLE_WINDOW_MS_CONFIG
metrics.sample.window.ms
public static final String METRICS_NUM_SAMPLES_CONFIG
metrics.num.samples
public static final String METRICS_RECORDING_LEVEL_CONFIG
metrics.log.level
public static final String METRIC_REPORTER_CLASSES_CONFIG
metric.reporters
public static final String CHECK_CRCS_CONFIG
check.crcs
public static final String KEY_DESERIALIZER_CLASS_CONFIG
key.deserializer
public static final String KEY_DESERIALIZER_CLASS_DOC
public static final String VALUE_DESERIALIZER_CLASS_CONFIG
value.deserializer
public static final String VALUE_DESERIALIZER_CLASS_DOC
public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms
public static final String REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
public static final String DEFAULT_API_TIMEOUT_MS_CONFIG
default.api.timeout.ms
public static final String DEFAULT_API_TIMEOUT_MS_DOC
public static final String INTERCEPTOR_CLASSES_CONFIG
interceptor.classes
public static final String INTERCEPTOR_CLASSES_DOC
public static final String EXCLUDE_INTERNAL_TOPICS_CONFIG
exclude.internal.topics
public static final boolean DEFAULT_EXCLUDE_INTERNAL_TOPICS
public static final String ISOLATION_LEVEL_CONFIG
isolation.level
public static final String ISOLATION_LEVEL_DOC
public static final String DEFAULT_ISOLATION_LEVEL
public static final String ALLOW_AUTO_CREATE_TOPICS_CONFIG
allow.auto.create.topics
public static final boolean DEFAULT_ALLOW_AUTO_CREATE_TOPICS
public ConsumerConfig(Properties props)
protected ConsumerConfig(Map<?,?> props, boolean doLog)
protected Map<String,Object> postProcessParsedConfig(Map<String,Object> parsedValues)
AbstractConfig
postProcessParsedConfig
in class AbstractConfig
parsedValues
- unmodifiable map of current configurationpublic static Map<String,Object> addDeserializerToConfig(Map<String,Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer)
public static Properties addDeserializerToConfig(Properties properties, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer)
public static ConfigDef configDef()
public static void main(String[] args)