public class ConsumerConfig extends AbstractConfig
AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG
Constructor and Description |
---|
ConsumerConfig(Map<String,Object> props) |
ConsumerConfig(Properties props) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
appendDeserializerToConfig(Map<String,Object> configs,
Deserializer<?> keyDeserializer,
Deserializer<?> valueDeserializer) |
static ConfigDef |
configDef() |
static Set<String> |
configNames() |
static void |
main(String[] args) |
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, 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 int DEFAULT_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 GROUP_PROTOCOL_CONFIG
group.protocol
public static final String DEFAULT_GROUP_PROTOCOL
public static final String GROUP_PROTOCOL_DOC
public static final String GROUP_REMOTE_ASSIGNOR_CONFIG
group.remote.assignor
public static final String DEFAULT_GROUP_REMOTE_ASSIGNOR
public static final String GROUP_REMOTE_ASSIGNOR_DOC
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 int DEFAULT_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 int DEFAULT_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 DEFAULT_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 ENABLE_METRICS_PUSH_CONFIG
enable.metrics.push
public static final String ENABLE_METRICS_PUSH_DOC
public static final String RETRY_BACKOFF_MAX_MS_CONFIG
retry.backoff.max.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
@Deprecated public static final String AUTO_INCLUDE_JMX_REPORTER_CONFIG
auto.include.jmx.reporter
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 SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
socket.connection.setup.timeout.ms
public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG
socket.connection.setup.timeout.max.ms
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 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 static final String SECURITY_PROVIDERS_CONFIG
security.providers
public static final String PROXY_PROTOCOL_CLIENT_VERSION
public static final String PROXY_PROTOCOL_CLIENT_VERSION_DOC
public static final String PROXY_PROTOCOL_CLIENT_VERSION_DEFAULT
public static final String PROXY_PROTOCOL_CLIENT_ADDRESS
public static final String PROXY_PROTOCOL_CLIENT_ADDRESS_DOC
public static final String PROXY_PROTOCOL_CLIENT_PORT
public static final String PROXY_PROTOCOL_CLIENT_PORT_DOC
public static final String PROXY_PROTOCOL_CLIENT_MODE
public static final String PROXY_PROTOCOL_CLIENT_MODE_DOC
public static final String PROXY_PROTOCOL_CLIENT_MODE_DEFAULT
public static final String LKC_ID
public static final String LKC_ID_DOC
public ConsumerConfig(Properties props)
public static Map<String,Object> appendDeserializerToConfig(Map<String,Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer)
public static ConfigDef configDef()
public static void main(String[] args)