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