Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.kafka.clients.consumer.ConsumerConfig

Modifier and Type	Constant Field	Value
public static final java.lang.String	AUTO_COMMIT_INTERVAL_MS_CONFIG	"auto.commit.interval.ms"
public static final java.lang.String	AUTO_OFFSET_RESET_CONFIG	"auto.offset.reset"
public static final java.lang.String	BOOTSTRAP_SERVERS_CONFIG	"bootstrap.servers"
public static final java.lang.String	CHECK_CRCS_CONFIG	"check.crcs"
public static final java.lang.String	CLIENT_ID_CONFIG	"client.id"
public static final java.lang.String	CONNECTIONS_MAX_IDLE_MS_CONFIG	"connections.max.idle.ms"
public static final java.lang.String	ENABLE_AUTO_COMMIT_CONFIG	"enable.auto.commit"
public static final java.lang.String	FETCH_MAX_WAIT_MS_CONFIG	"fetch.max.wait.ms"
public static final java.lang.String	FETCH_MIN_BYTES_CONFIG	"fetch.min.bytes"
public static final java.lang.String	GROUP_ID_CONFIG	"group.id"
public static final java.lang.String	HEARTBEAT_INTERVAL_MS_CONFIG	"heartbeat.interval.ms"
public static final java.lang.String	KEY_DESERIALIZER_CLASS_CONFIG	"key.deserializer"
public static final java.lang.String	KEY_DESERIALIZER_CLASS_DOC	"Deserializer class for key that implements the <code>Deserializer</code> interface."
public static final java.lang.String	MAX_PARTITION_FETCH_BYTES_CONFIG	"max.partition.fetch.bytes"
public static final java.lang.String	METADATA_MAX_AGE_CONFIG	"metadata.max.age.ms"
public static final java.lang.String	METRIC_REPORTER_CLASSES_CONFIG	"metric.reporters"
public static final java.lang.String	METRICS_NUM_SAMPLES_CONFIG	"metrics.num.samples"
public static final java.lang.String	METRICS_SAMPLE_WINDOW_MS_CONFIG	"metrics.sample.window.ms"
public static final java.lang.String	PARTITION_ASSIGNMENT_STRATEGY_CONFIG	"partition.assignment.strategy"
public static final java.lang.String	RECEIVE_BUFFER_CONFIG	"receive.buffer.bytes"
public static final java.lang.String	RECONNECT_BACKOFF_MS_CONFIG	"reconnect.backoff.ms"
public static final java.lang.String	REQUEST_TIMEOUT_MS_CONFIG	"request.timeout.ms"
public static final java.lang.String	RETRY_BACKOFF_MS_CONFIG	"retry.backoff.ms"
public static final java.lang.String	SEND_BUFFER_CONFIG	"send.buffer.bytes"
public static final java.lang.String	SESSION_TIMEOUT_MS_CONFIG	"session.timeout.ms"
public static final java.lang.String	VALUE_DESERIALIZER_CLASS_CONFIG	"value.deserializer"
public static final java.lang.String	VALUE_DESERIALIZER_CLASS_DOC	"Deserializer class for value that implements the <code>Deserializer</code> interface."

org.apache.kafka.clients.producer.ProducerConfig

Modifier and Type	Constant Field	Value
public static final java.lang.String	ACKS_CONFIG	"acks"
public static final java.lang.String	BATCH_SIZE_CONFIG	"batch.size"
public static final java.lang.String	BLOCK_ON_BUFFER_FULL_CONFIG	"block.on.buffer.full"
public static final java.lang.String	BOOTSTRAP_SERVERS_CONFIG	"bootstrap.servers"
public static final java.lang.String	BUFFER_MEMORY_CONFIG	"buffer.memory"
public static final java.lang.String	CLIENT_ID_CONFIG	"client.id"
public static final java.lang.String	COMPRESSION_TYPE_CONFIG	"compression.type"
public static final java.lang.String	CONNECTIONS_MAX_IDLE_MS_CONFIG	"connections.max.idle.ms"
public static final java.lang.String	KEY_SERIALIZER_CLASS_CONFIG	"key.serializer"
public static final java.lang.String	KEY_SERIALIZER_CLASS_DOC	"Serializer class for key that implements the <code>Serializer</code> interface."
public static final java.lang.String	LINGER_MS_CONFIG	"linger.ms"
public static final java.lang.String	MAX_BLOCK_MS_CONFIG	"max.block.ms"
public static final java.lang.String	MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION	"max.in.flight.requests.per.connection"
public static final java.lang.String	MAX_REQUEST_SIZE_CONFIG	"max.request.size"
public static final java.lang.String	METADATA_FETCH_TIMEOUT_CONFIG	"metadata.fetch.timeout.ms"
public static final java.lang.String	METADATA_MAX_AGE_CONFIG	"metadata.max.age.ms"
public static final java.lang.String	METRIC_REPORTER_CLASSES_CONFIG	"metric.reporters"
public static final java.lang.String	METRICS_NUM_SAMPLES_CONFIG	"metrics.num.samples"
public static final java.lang.String	METRICS_SAMPLE_WINDOW_MS_CONFIG	"metrics.sample.window.ms"
public static final java.lang.String	PARTITIONER_CLASS_CONFIG	"partitioner.class"
public static final java.lang.String	RECEIVE_BUFFER_CONFIG	"receive.buffer.bytes"
public static final java.lang.String	RECONNECT_BACKOFF_MS_CONFIG	"reconnect.backoff.ms"
public static final java.lang.String	REQUEST_TIMEOUT_MS_CONFIG	"request.timeout.ms"
public static final java.lang.String	RETRIES_CONFIG	"retries"
public static final java.lang.String	RETRY_BACKOFF_MS_CONFIG	"retry.backoff.ms"
public static final java.lang.String	SEND_BUFFER_CONFIG	"send.buffer.bytes"
public static final java.lang.String	TIMEOUT_CONFIG	"timeout.ms"
public static final java.lang.String	VALUE_SERIALIZER_CLASS_CONFIG	"value.serializer"
public static final java.lang.String	VALUE_SERIALIZER_CLASS_DOC	"Serializer class for value that implements the <code>Serializer</code> interface."