Constant Field Values

Contents

• com.rabbitmq.*
• fr.codinbox.*
• org.apache.*
• org.redisson.*

com.rabbitmq.*

com.rabbitmq.client.AMQP

Modifier and Type	Constant Field	Value
public static final int	ACCESS_REFUSED	403
public static final int	CHANNEL_ERROR	504
public static final int	COMMAND_INVALID	503
public static final int	CONNECTION_FORCED	320
public static final int	CONTENT_TOO_LARGE	311
public static final int	FRAME_BODY	3
public static final int	FRAME_END	206
public static final int	FRAME_ERROR	501
public static final int	FRAME_HEADER	2
public static final int	FRAME_HEARTBEAT	8
public static final int	FRAME_METHOD	1
public static final int	FRAME_MIN_SIZE	4096
public static final int	INTERNAL_ERROR	541
public static final int	INVALID_PATH	402
public static final int	NO_CONSUMERS	313
public static final int	NO_ROUTE	312
public static final int	NOT_ALLOWED	530
public static final int	NOT_FOUND	404
public static final int	NOT_IMPLEMENTED	540
public static final int	PRECONDITION_FAILED	406
public static final int	REPLY_SUCCESS	200
public static final int	RESOURCE_ERROR	506
public static final int	RESOURCE_LOCKED	405
public static final int	SYNTAX_ERROR	502
public static final int	UNEXPECTED_FRAME	505

com.rabbitmq.client.AMQP.PROTOCOL

Modifier and Type	Constant Field	Value
public static final int	MAJOR	0
public static final int	MINOR	9
public static final int	PORT	5672
public static final int	REVISION	1

com.rabbitmq.client.ConnectionFactory

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_AMQP_OVER_SSL_PORT	5671
public static final int	DEFAULT_AMQP_PORT	5672
public static final int	DEFAULT_CHANNEL_MAX	2047
public static final int	DEFAULT_CONNECTION_TIMEOUT	60000
public static final int	DEFAULT_FRAME_MAX	0
public static final int	DEFAULT_HANDSHAKE_TIMEOUT	10000
public static final int	DEFAULT_HEARTBEAT	60
public static final String	DEFAULT_HOST	"localhost"
public static final long	DEFAULT_NETWORK_RECOVERY_INTERVAL	5000L
public static final String	DEFAULT_PASS	"guest"
public static final int	DEFAULT_SHUTDOWN_TIMEOUT	10000
public static final String	DEFAULT_USER	"guest"
public static final String	DEFAULT_VHOST	"/"
public static final int	DEFAULT_WORK_POOL_TIMEOUT	-1
public static final int	USE_DEFAULT_PORT	-1

com.rabbitmq.client.ConnectionFactoryConfigurator

Modifier and Type	Constant Field	Value
public static final String	CHANNEL_RPC_TIMEOUT	"channel.rpc.timeout"
public static final String	CHANNEL_SHOULD_CHECK_RPC_RESPONSE_TYPE	"channel.should.check.rpc.response.type"
public static final String	CLIENT_PROPERTIES_PREFIX	"client.properties."
public static final String	CONNECTION_CHANNEL_MAX	"connection.channel.max"
public static final String	CONNECTION_FRAME_MAX	"connection.frame.max"
public static final String	CONNECTION_HEARTBEAT	"connection.heartbeat"
public static final String	CONNECTION_RECOVERY_ENABLED	"connection.recovery.enabled"
public static final String	CONNECTION_RECOVERY_INTERVAL	"connection.recovery.interval"
public static final String	CONNECTION_TIMEOUT	"connection.timeout"
public static final String	DEFAULT_PREFIX	"rabbitmq."
public static final String	HANDSHAKE_TIMEOUT	"handshake.timeout"
public static final String	HOST	"host"
public static final String	NIO_NB_IO_THREADS	"nio.nb.io.threads"
public static final String	NIO_READ_BYTE_BUFFER_SIZE	"nio.read.byte.buffer.size"
public static final String	NIO_WRITE_BYTE_BUFFER_SIZE	"nio.write.byte.buffer.size"
public static final String	NIO_WRITE_ENQUEUING_TIMEOUT_IN_MS	"nio.write.enqueuing.timeout.in.ms"
public static final String	NIO_WRITE_QUEUE_CAPACITY	"nio.write.queue.capacity"
public static final String	PASSWORD	"password"
public static final String	PORT	"port"
public static final String	SHUTDOWN_TIMEOUT	"shutdown.timeout"
public static final String	SSL_ALGORITHM	"ssl.algorithm"
public static final String	SSL_ENABLED	"ssl.enabled"
public static final String	SSL_KEY_STORE	"ssl.key.store"
public static final String	SSL_KEY_STORE_ALGORITHM	"ssl.key.store.algorithm"
public static final String	SSL_KEY_STORE_PASSWORD	"ssl.key.store.password"
public static final String	SSL_KEY_STORE_TYPE	"ssl.key.store.type"
public static final String	SSL_TRUST_STORE	"ssl.trust.store"
public static final String	SSL_TRUST_STORE_ALGORITHM	"ssl.trust.store.algorithm"
public static final String	SSL_TRUST_STORE_PASSWORD	"ssl.trust.store.password"
public static final String	SSL_TRUST_STORE_TYPE	"ssl.trust.store.type"
public static final String	SSL_VALIDATE_SERVER_CERTIFICATE	"ssl.validate.server.certificate"
public static final String	SSL_VERIFY_HOSTNAME	"ssl.verify.hostname"
public static final String	TOPOLOGY_RECOVERY_ENABLED	"topology.recovery.enabled"
public static final String	USE_NIO	"use.nio"
public static final String	USERNAME	"username"
public static final String	VIRTUAL_HOST	"virtual.host"

com.rabbitmq.client.LongString

Modifier and Type	Constant Field	Value
public static final long	MAX_LENGTH	4294967295L

com.rabbitmq.client.RpcClient

Modifier and Type	Constant Field	Value
protected static final int	NO_TIMEOUT	-1

com.rabbitmq.client.StringRpcServer

Modifier and Type	Constant Field	Value
public static final String	STRING_ENCODING	"UTF-8"

com.rabbitmq.client.impl.AMQChannel

Modifier and Type	Constant Field	Value
protected static final int	NO_RPC_TIMEOUT	0

com.rabbitmq.client.impl.AMQCommand

Modifier and Type	Constant Field	Value
public static final int	EMPTY_FRAME_SIZE	8

com.rabbitmq.client.impl.AMQConnection

Modifier and Type	Constant Field	Value
public static final double	CHANNEL_SHUTDOWN_TIMEOUT_MULTIPLIER	1.05

com.rabbitmq.client.impl.AMQImpl.Access

Modifier and Type	Constant Field	Value
public static final int	INDEX	30

com.rabbitmq.client.impl.AMQImpl.Access.Request

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Access.RequestOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.AMQImpl.Basic

Modifier and Type	Constant Field	Value
public static final int	INDEX	60

com.rabbitmq.client.impl.AMQImpl.Basic.Ack

Modifier and Type	Constant Field	Value
public static final int	INDEX	80

com.rabbitmq.client.impl.AMQImpl.Basic.Cancel

Modifier and Type	Constant Field	Value
public static final int	INDEX	30

com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	31

com.rabbitmq.client.impl.AMQImpl.Basic.Consume

Modifier and Type	Constant Field	Value
public static final int	INDEX	20

com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	21

com.rabbitmq.client.impl.AMQImpl.Basic.Deliver

Modifier and Type	Constant Field	Value
public static final int	INDEX	60

com.rabbitmq.client.impl.AMQImpl.Basic.Get

Modifier and Type	Constant Field	Value
public static final int	INDEX	70

com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty

Modifier and Type	Constant Field	Value
public static final int	INDEX	72

com.rabbitmq.client.impl.AMQImpl.Basic.GetOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	71

com.rabbitmq.client.impl.AMQImpl.Basic.Nack

Modifier and Type	Constant Field	Value
public static final int	INDEX	120

com.rabbitmq.client.impl.AMQImpl.Basic.Publish

Modifier and Type	Constant Field	Value
public static final int	INDEX	40

com.rabbitmq.client.impl.AMQImpl.Basic.Qos

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Basic.QosOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.AMQImpl.Basic.Recover

Modifier and Type	Constant Field	Value
public static final int	INDEX	110

com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync

Modifier and Type	Constant Field	Value
public static final int	INDEX	100

com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	111

com.rabbitmq.client.impl.AMQImpl.Basic.Reject

Modifier and Type	Constant Field	Value
public static final int	INDEX	90

com.rabbitmq.client.impl.AMQImpl.Basic.Return

Modifier and Type	Constant Field	Value
public static final int	INDEX	50

com.rabbitmq.client.impl.AMQImpl.Channel

Modifier and Type	Constant Field	Value
public static final int	INDEX	20

com.rabbitmq.client.impl.AMQImpl.Channel.Close

Modifier and Type	Constant Field	Value
public static final int	INDEX	40

com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	41

com.rabbitmq.client.impl.AMQImpl.Channel.Flow

Modifier and Type	Constant Field	Value
public static final int	INDEX	20

com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	21

com.rabbitmq.client.impl.AMQImpl.Channel.Open

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.AMQImpl.Confirm

Modifier and Type	Constant Field	Value
public static final int	INDEX	85

com.rabbitmq.client.impl.AMQImpl.Confirm.Select

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.AMQImpl.Connection

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Connection.Blocked

Modifier and Type	Constant Field	Value
public static final int	INDEX	60

com.rabbitmq.client.impl.AMQImpl.Connection.Close

Modifier and Type	Constant Field	Value
public static final int	INDEX	50

com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	51

com.rabbitmq.client.impl.AMQImpl.Connection.Open

Modifier and Type	Constant Field	Value
public static final int	INDEX	40

com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	41

com.rabbitmq.client.impl.AMQImpl.Connection.Secure

Modifier and Type	Constant Field	Value
public static final int	INDEX	20

com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	21

com.rabbitmq.client.impl.AMQImpl.Connection.Start

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Connection.StartOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.AMQImpl.Connection.Tune

Modifier and Type	Constant Field	Value
public static final int	INDEX	30

com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	31

com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked

Modifier and Type	Constant Field	Value
public static final int	INDEX	61

com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret

Modifier and Type	Constant Field	Value
public static final int	INDEX	70

com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecretOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	71

com.rabbitmq.client.impl.AMQImpl.Exchange

Modifier and Type	Constant Field	Value
public static final int	INDEX	40

com.rabbitmq.client.impl.AMQImpl.Exchange.Bind

Modifier and Type	Constant Field	Value
public static final int	INDEX	30

com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	31

com.rabbitmq.client.impl.AMQImpl.Exchange.Declare

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.AMQImpl.Exchange.Delete

Modifier and Type	Constant Field	Value
public static final int	INDEX	20

com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	21

com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind

Modifier and Type	Constant Field	Value
public static final int	INDEX	40

com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	51

com.rabbitmq.client.impl.AMQImpl.Queue

Modifier and Type	Constant Field	Value
public static final int	INDEX	50

com.rabbitmq.client.impl.AMQImpl.Queue.Bind

Modifier and Type	Constant Field	Value
public static final int	INDEX	20

com.rabbitmq.client.impl.AMQImpl.Queue.BindOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	21

com.rabbitmq.client.impl.AMQImpl.Queue.Declare

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.AMQImpl.Queue.Delete

Modifier and Type	Constant Field	Value
public static final int	INDEX	40

com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	41

com.rabbitmq.client.impl.AMQImpl.Queue.Purge

Modifier and Type	Constant Field	Value
public static final int	INDEX	30

com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	31

com.rabbitmq.client.impl.AMQImpl.Queue.Unbind

Modifier and Type	Constant Field	Value
public static final int	INDEX	50

com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	51

com.rabbitmq.client.impl.AMQImpl.Tx

Modifier and Type	Constant Field	Value
public static final int	INDEX	90

com.rabbitmq.client.impl.AMQImpl.Tx.Commit

Modifier and Type	Constant Field	Value
public static final int	INDEX	20

com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	21

com.rabbitmq.client.impl.AMQImpl.Tx.Rollback

Modifier and Type	Constant Field	Value
public static final int	INDEX	30

com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	31

com.rabbitmq.client.impl.AMQImpl.Tx.Select

Modifier and Type	Constant Field	Value
public static final int	INDEX	10

com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk

Modifier and Type	Constant Field	Value
public static final int	INDEX	11

com.rabbitmq.client.impl.SocketFrameHandler

Modifier and Type	Constant Field	Value
public static final int	SOCKET_CLOSING_TIMEOUT	1

com.rabbitmq.client.impl.recovery.RecordedQueue

Modifier and Type	Constant Field	Value
public static final String	EMPTY_STRING	""

fr.codinbox.*

fr.codinbox.connector.commons.utils.EnvUtils

Modifier and Type	Constant Field	Value
public static final @NotNull String	KAFKA_PREFIX	"CONNECTOR_KAFKA_"
public static final @NotNull String	MYSQL_PREFIX	"CONNECTOR_DB_"
public static final @NotNull String	RABBITMQ_PREFIX	"CONNECTOR_RABBITMQ_"
public static final @NotNull String	REDIS_PREFIX	"CONNECTOR_REDIS_"

org.apache.*

org.apache.kafka.clients.admin.AdminClientConfig

Modifier and Type	Constant Field	Value
public static final String	AUTO_INCLUDE_JMX_REPORTER_CONFIG	"auto.include.jmx.reporter"
public static final String	AUTO_INCLUDE_JMX_REPORTER_DOC	"Deprecated. Whether to automatically include JmxReporter even if it\'s not listed in <code>metric.reporters</code>. This configuration will be removed in Kafka 4.0, users should instead include <code>org.apache.kafka.common.metrics.JmxReporter</code> in <code>metric.reporters</code> in order to enable the JmxReporter."
public static final String	BOOTSTRAP_CONTROLLERS_CONFIG	"bootstrap.controllers"
public static final String	BOOTSTRAP_CONTROLLERS_DOC	"A list of host/port pairs to use for establishing the initial connection to the KRaft controller quorum. This list should be in the form <code>host1:port1,host2:port2,...</code>."
public static final String	BOOTSTRAP_SERVERS_CONFIG	"bootstrap.servers"
public static final String	CLIENT_DNS_LOOKUP_CONFIG	"client.dns.lookup"
public static final String	CLIENT_ID_CONFIG	"client.id"
public static final String	CONNECTIONS_MAX_IDLE_MS_CONFIG	"connections.max.idle.ms"
public static final String	DEFAULT_API_TIMEOUT_MS_CONFIG	"default.api.timeout.ms"
public static final String	DEFAULT_SECURITY_PROTOCOL	"PLAINTEXT"
public static final String	ENABLE_METRICS_PUSH_CONFIG	"enable.metrics.push"
public static final String	ENABLE_METRICS_PUSH_DOC	"Whether to enable pushing of client metrics to the cluster, if the cluster has a client metrics subscription which matches this client."
public static final String	METADATA_MAX_AGE_CONFIG	"metadata.max.age.ms"
public static final String	METRIC_REPORTER_CLASSES_CONFIG	"metric.reporters"
public static final String	METRICS_NUM_SAMPLES_CONFIG	"metrics.num.samples"
public static final String	METRICS_RECORDING_LEVEL_CONFIG	"metrics.recording.level"
public static final String	METRICS_SAMPLE_WINDOW_MS_CONFIG	"metrics.sample.window.ms"
public static final String	RECEIVE_BUFFER_CONFIG	"receive.buffer.bytes"
public static final String	RECONNECT_BACKOFF_MAX_MS_CONFIG	"reconnect.backoff.max.ms"
public static final String	RECONNECT_BACKOFF_MS_CONFIG	"reconnect.backoff.ms"
public static final String	REQUEST_TIMEOUT_MS_CONFIG	"request.timeout.ms"
public static final String	RETRIES_CONFIG	"retries"
public static final String	RETRY_BACKOFF_MAX_MS_CONFIG	"retry.backoff.max.ms"
public static final String	RETRY_BACKOFF_MS_CONFIG	"retry.backoff.ms"
public static final String	SECURITY_PROTOCOL_CONFIG	"security.protocol"
public static final String	SECURITY_PROVIDERS_CONFIG	"security.providers"
public static final String	SEND_BUFFER_CONFIG	"send.buffer.bytes"
public static final String	SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG	"socket.connection.setup.timeout.max.ms"
public static final String	SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG	"socket.connection.setup.timeout.ms"

org.apache.kafka.clients.consumer.ConsumerConfig

Modifier and Type	Constant Field	Value
public static final String	ALLOW_AUTO_CREATE_TOPICS_CONFIG	"allow.auto.create.topics"
public static final String	AUTO_COMMIT_INTERVAL_MS_CONFIG	"auto.commit.interval.ms"
public static final String	AUTO_INCLUDE_JMX_REPORTER_CONFIG	"auto.include.jmx.reporter"
public static final String	AUTO_OFFSET_RESET_CONFIG	"auto.offset.reset"
public static final String	AUTO_OFFSET_RESET_DOC	"What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g. because that data has been deleted): <ul><li>earliest: automatically reset the offset to the earliest offset<li>latest: automatically reset the offset to the latest offset</li><li>none: throw exception to the consumer if no previous offset is found for the consumer\'s group</li><li>anything else: throw exception to the consumer.</li></ul><p>Note that altering partition numbers while setting this config to latest may cause message delivery loss since producers could start to send messages to newly added partitions (i.e. no initial offsets exist yet) before consumers reset their offsets."
public static final String	BOOTSTRAP_SERVERS_CONFIG	"bootstrap.servers"
public static final String	CHECK_CRCS_CONFIG	"check.crcs"
public static final String	CLIENT_DNS_LOOKUP_CONFIG	"client.dns.lookup"
public static final String	CLIENT_ID_CONFIG	"client.id"
public static final String	CLIENT_RACK_CONFIG	"client.rack"
public static final String	CONNECTIONS_MAX_IDLE_MS_CONFIG	"connections.max.idle.ms"
public static final boolean	DEFAULT_ALLOW_AUTO_CREATE_TOPICS	true
public static final String	DEFAULT_API_TIMEOUT_MS_CONFIG	"default.api.timeout.ms"
public static final String	DEFAULT_CLIENT_RACK	""
public static final boolean	DEFAULT_EXCLUDE_INTERNAL_TOPICS	true
public static final int	DEFAULT_FETCH_MAX_BYTES	52428800
public static final int	DEFAULT_FETCH_MAX_WAIT_MS	500
public static final int	DEFAULT_FETCH_MIN_BYTES	1
public static final int	DEFAULT_MAX_PARTITION_FETCH_BYTES	1048576
public static final int	DEFAULT_MAX_POLL_RECORDS	500
public static final String	ENABLE_AUTO_COMMIT_CONFIG	"enable.auto.commit"
public static final String	ENABLE_METRICS_PUSH_CONFIG	"enable.metrics.push"
public static final String	ENABLE_METRICS_PUSH_DOC	"Whether to enable pushing of client metrics to the cluster, if the cluster has a client metrics subscription which matches this client."
public static final String	EXCLUDE_INTERNAL_TOPICS_CONFIG	"exclude.internal.topics"
public static final String	FETCH_MAX_BYTES_CONFIG	"fetch.max.bytes"
public static final String	FETCH_MAX_WAIT_MS_CONFIG	"fetch.max.wait.ms"
public static final String	FETCH_MIN_BYTES_CONFIG	"fetch.min.bytes"
public static final String	GROUP_ID_CONFIG	"group.id"
public static final String	GROUP_INSTANCE_ID_CONFIG	"group.instance.id"
public static final String	GROUP_PROTOCOL_CONFIG	"group.protocol"
public static final String	GROUP_PROTOCOL_DOC	"The group protocol consumer should use. We currently support \"classic\" or \"consumer\". If \"consumer\" is specified, then the consumer group protocol will be used. Otherwise, the classic group protocol will be used."
public static final String	GROUP_REMOTE_ASSIGNOR_CONFIG	"group.remote.assignor"
public static final String	GROUP_REMOTE_ASSIGNOR_DOC	"The server-side assignor to use. If no assignor is specified, the group coordinator will pick one. This configuration is applied only if <code>group.protocol</code> is set to \"consumer\"."
public static final String	HEARTBEAT_INTERVAL_MS_CONFIG	"heartbeat.interval.ms"
public static final String	INTERCEPTOR_CLASSES_CONFIG	"interceptor.classes"
public static final String	INTERCEPTOR_CLASSES_DOC	"A list of classes to use as interceptors. Implementing the <code>org.apache.kafka.clients.consumer.ConsumerInterceptor</code> interface allows you to intercept (and possibly mutate) records received by the consumer. By default, there are no interceptors."
public static final String	ISOLATION_LEVEL_CONFIG	"isolation.level"
public static final String	ISOLATION_LEVEL_DOC	"Controls how to read messages written transactionally. If set to <code>read_committed</code>, consumer.poll() will only return transactional messages which have been committed. If set to <code>read_uncommitted</code> (the default), consumer.poll() will return all messages, even transactional messages which have been aborted. Non-transactional messages will be returned unconditionally in either mode. <p>Messages will always be returned in offset order. Hence, in <code>read_committed</code> mode, consumer.poll() will only return messages up to the last stable offset (LSO), which is the one less than the offset of the first open transaction. In particular any messages appearing after messages belonging to ongoing transactions will be withheld until the relevant transaction has been completed. As a result, <code>read_committed</code> consumers will not be able to read up to the high watermark when there are in flight transactions.</p><p> Further, when in <code>read_committed</code> the seekToEnd method will return the LSO</p>"
public static final String	KEY_DESERIALIZER_CLASS_CONFIG	"key.deserializer"
public static final String	KEY_DESERIALIZER_CLASS_DOC	"Deserializer class for key that implements the <code>org.apache.kafka.common.serialization.Deserializer</code> interface."
public static final String	MAX_PARTITION_FETCH_BYTES_CONFIG	"max.partition.fetch.bytes"
public static final String	MAX_POLL_INTERVAL_MS_CONFIG	"max.poll.interval.ms"
public static final String	MAX_POLL_RECORDS_CONFIG	"max.poll.records"
public static final String	METADATA_MAX_AGE_CONFIG	"metadata.max.age.ms"
public static final String	METRIC_REPORTER_CLASSES_CONFIG	"metric.reporters"
public static final String	METRICS_NUM_SAMPLES_CONFIG	"metrics.num.samples"
public static final String	METRICS_RECORDING_LEVEL_CONFIG	"metrics.recording.level"
public static final String	METRICS_SAMPLE_WINDOW_MS_CONFIG	"metrics.sample.window.ms"
public static final String	PARTITION_ASSIGNMENT_STRATEGY_CONFIG	"partition.assignment.strategy"
public static final String	RECEIVE_BUFFER_CONFIG	"receive.buffer.bytes"
public static final String	RECONNECT_BACKOFF_MAX_MS_CONFIG	"reconnect.backoff.max.ms"
public static final String	RECONNECT_BACKOFF_MS_CONFIG	"reconnect.backoff.ms"
public static final String	REQUEST_TIMEOUT_MS_CONFIG	"request.timeout.ms"
public static final String	RETRY_BACKOFF_MAX_MS_CONFIG	"retry.backoff.max.ms"
public static final String	RETRY_BACKOFF_MS_CONFIG	"retry.backoff.ms"
public static final String	SECURITY_PROVIDERS_CONFIG	"security.providers"
public static final String	SEND_BUFFER_CONFIG	"send.buffer.bytes"
public static final String	SESSION_TIMEOUT_MS_CONFIG	"session.timeout.ms"
public static final String	SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG	"socket.connection.setup.timeout.max.ms"
public static final String	SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG	"socket.connection.setup.timeout.ms"
public static final String	VALUE_DESERIALIZER_CLASS_CONFIG	"value.deserializer"
public static final String	VALUE_DESERIALIZER_CLASS_DOC	"Deserializer class for value that implements the <code>org.apache.kafka.common.serialization.Deserializer</code> interface."

org.apache.kafka.clients.consumer.ConsumerRecord<K,V>

Modifier and Type	Constant Field	Value
public static final long	NO_TIMESTAMP	-1L
public static final int	NULL_CHECKSUM	-1
public static final int	NULL_SIZE	-1

org.apache.kafka.clients.consumer.CooperativeStickyAssignor

Modifier and Type	Constant Field	Value
public static final String	COOPERATIVE_STICKY_ASSIGNOR_NAME	"cooperative-sticky"

org.apache.kafka.clients.consumer.RangeAssignor

Modifier and Type	Constant Field	Value
public static final String	RANGE_ASSIGNOR_NAME	"range"

org.apache.kafka.clients.consumer.RoundRobinAssignor

Modifier and Type	Constant Field	Value
public static final String	ROUNDROBIN_ASSIGNOR_NAME	"roundrobin"

org.apache.kafka.clients.consumer.StickyAssignor

Modifier and Type	Constant Field	Value
public static final String	STICKY_ASSIGNOR_NAME	"sticky"

org.apache.kafka.clients.consumer.internals.AbstractCoordinator

Modifier and Type	Constant Field	Value
public static final String	HEARTBEAT_THREAD_PREFIX	"kafka-coordinator-heartbeat-thread"
public static final int	JOIN_GROUP_TIMEOUT_LAPSE	5000

org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_GENERATION	-1

org.apache.kafka.clients.consumer.internals.ConsumerProtocol

Modifier and Type	Constant Field	Value
public static final String	PROTOCOL_TYPE	"consumer"

org.apache.kafka.clients.consumer.internals.ConsumerUtils

Modifier and Type	Constant Field	Value
public static final String	CONSUMER_JMX_PREFIX	"kafka.consumer"
public static final int	CONSUMER_MAX_INFLIGHT_REQUESTS_PER_CONNECTION	100
public static final String	CONSUMER_METRIC_GROUP_PREFIX	"consumer"
public static final long	DEFAULT_CLOSE_TIMEOUT_MS	30000L

org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer<K,V>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_REASON	"rebalance enforced by user"

org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.PollResult

Modifier and Type	Constant Field	Value
public static final long	WAIT_FOREVER	9223372036854775807L

org.apache.kafka.clients.producer.KafkaProducer<K,V>

Modifier and Type	Constant Field	Value
public static final String	NETWORK_THREAD_PREFIX	"kafka-producer-network-thread"
public static final String	PRODUCER_METRIC_GROUP_NAME	"producer-metrics"

org.apache.kafka.clients.producer.ProducerConfig

Modifier and Type	Constant Field	Value
public static final String	ACKS_CONFIG	"acks"
public static final String	AUTO_INCLUDE_JMX_REPORTER_CONFIG	"auto.include.jmx.reporter"
public static final String	BATCH_SIZE_CONFIG	"batch.size"
public static final String	BOOTSTRAP_SERVERS_CONFIG	"bootstrap.servers"
public static final String	BUFFER_MEMORY_CONFIG	"buffer.memory"
public static final String	CLIENT_DNS_LOOKUP_CONFIG	"client.dns.lookup"
public static final String	CLIENT_ID_CONFIG	"client.id"
public static final String	COMPRESSION_TYPE_CONFIG	"compression.type"
public static final String	CONNECTIONS_MAX_IDLE_MS_CONFIG	"connections.max.idle.ms"
public static final String	DELIVERY_TIMEOUT_MS_CONFIG	"delivery.timeout.ms"
public static final String	ENABLE_IDEMPOTENCE_CONFIG	"enable.idempotence"
public static final String	ENABLE_IDEMPOTENCE_DOC	"When set to \'true\', the producer will ensure that exactly one copy of each message is written in the stream. If \'false\', producer retries due to broker failures, etc., may write duplicates of the retried message in the stream. Note that enabling idempotence requires <code>max.in.flight.requests.per.connection</code> to be less than or equal to 5 (with message ordering preserved for any allowable value), <code>retries</code> to be greater than 0, and <code>acks</code> must be \'all\'. <p>Idempotence is enabled by default if no conflicting configurations are set. If conflicting configurations are set and idempotence is not explicitly enabled, idempotence is disabled. If idempotence is explicitly enabled and conflicting configurations are set, a <code>ConfigException</code> is thrown."
public static final String	ENABLE_METRICS_PUSH_CONFIG	"enable.metrics.push"
public static final String	ENABLE_METRICS_PUSH_DOC	"Whether to enable pushing of client metrics to the cluster, if the cluster has a client metrics subscription which matches this client."
public static final String	INTERCEPTOR_CLASSES_CONFIG	"interceptor.classes"
public static final String	INTERCEPTOR_CLASSES_DOC	"A list of classes to use as interceptors. Implementing the <code>org.apache.kafka.clients.producer.ProducerInterceptor</code> interface allows you to intercept (and possibly mutate) the records received by the producer before they are published to the Kafka cluster. By default, there are no interceptors."
public static final String	KEY_SERIALIZER_CLASS_CONFIG	"key.serializer"
public static final String	KEY_SERIALIZER_CLASS_DOC	"Serializer class for key that implements the <code>org.apache.kafka.common.serialization.Serializer</code> interface."
public static final String	LINGER_MS_CONFIG	"linger.ms"
public static final String	MAX_BLOCK_MS_CONFIG	"max.block.ms"
public static final String	MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION	"max.in.flight.requests.per.connection"
public static final String	MAX_REQUEST_SIZE_CONFIG	"max.request.size"
public static final String	METADATA_MAX_AGE_CONFIG	"metadata.max.age.ms"
public static final String	METADATA_MAX_IDLE_CONFIG	"metadata.max.idle.ms"
public static final String	METRIC_REPORTER_CLASSES_CONFIG	"metric.reporters"
public static final String	METRICS_NUM_SAMPLES_CONFIG	"metrics.num.samples"
public static final String	METRICS_RECORDING_LEVEL_CONFIG	"metrics.recording.level"
public static final String	METRICS_SAMPLE_WINDOW_MS_CONFIG	"metrics.sample.window.ms"
public static final String	PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG	"partitioner.adaptive.partitioning.enable"
public static final String	PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG	"partitioner.availability.timeout.ms"
public static final String	PARTITIONER_CLASS_CONFIG	"partitioner.class"
public static final String	PARTITIONER_IGNORE_KEYS_CONFIG	"partitioner.ignore.keys"
public static final String	RECEIVE_BUFFER_CONFIG	"receive.buffer.bytes"
public static final String	RECONNECT_BACKOFF_MAX_MS_CONFIG	"reconnect.backoff.max.ms"
public static final String	RECONNECT_BACKOFF_MS_CONFIG	"reconnect.backoff.ms"
public static final String	REQUEST_TIMEOUT_MS_CONFIG	"request.timeout.ms"
public static final String	RETRIES_CONFIG	"retries"
public static final String	RETRY_BACKOFF_MAX_MS_CONFIG	"retry.backoff.max.ms"
public static final String	RETRY_BACKOFF_MS_CONFIG	"retry.backoff.ms"
public static final String	SECURITY_PROVIDERS_CONFIG	"security.providers"
public static final String	SEND_BUFFER_CONFIG	"send.buffer.bytes"
public static final String	SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG	"socket.connection.setup.timeout.max.ms"
public static final String	SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG	"socket.connection.setup.timeout.ms"
public static final String	TRANSACTION_TIMEOUT_CONFIG	"transaction.timeout.ms"
public static final String	TRANSACTION_TIMEOUT_DOC	"The maximum amount of time in milliseconds that a transaction will remain open before the coordinator proactively aborts it. The start of the transaction is set at the time that the first partition is added to it. If this value is larger than the <code>transaction.max.timeout.ms</code> setting in the broker, the request will fail with a <code>InvalidTxnTimeoutException</code> error."
public static final String	TRANSACTIONAL_ID_CONFIG	"transactional.id"
public static final String	TRANSACTIONAL_ID_DOC	"The TransactionalId to use for transactional delivery. This enables reliability semantics which span multiple producer sessions since it allows the client to guarantee that transactions using the same TransactionalId have been completed prior to starting any new transactions. If no TransactionalId is provided, then the producer is limited to idempotent delivery. If a TransactionalId is configured, <code>enable.idempotence</code> is implied. By default the TransactionId is not configured, which means transactions cannot be used. Note that, by default, transactions require a cluster of at least three brokers which is the recommended setting for production; for development you can change this, by adjusting broker setting <code>transaction.state.log.replication.factor</code>."
public static final String	VALUE_SERIALIZER_CLASS_CONFIG	"value.serializer"
public static final String	VALUE_SERIALIZER_CLASS_DOC	"Serializer class for value that implements the <code>org.apache.kafka.common.serialization.Serializer</code> interface."

org.apache.kafka.clients.producer.RecordMetadata

Modifier and Type	Constant Field	Value
public static final int	UNKNOWN_PARTITION	-1

org.apache.kafka.clients.producer.internals.KafkaProducerMetrics

Modifier and Type	Constant Field	Value
public static final String	GROUP	"producer-metrics"

org.redisson.*

org.redisson.api.RExecutorService

Modifier and Type	Constant Field	Value
public static final String	MAPREDUCE_NAME	"redisson_mapreduce"