false true low Whether to enable pushing of client metrics to the cluster， all medium A comma-separated list of debug contexts to enable. Detailed Producer debugging: broker， improved compression) batches of messages to accumulate at the expense of increased message delivery latency. Type: float message.send.max.retries P 0 .. 2147483647 2147483647 high How many times to retry sending a failing Message. Note: retrying may cause reordering unless enable.idempotence is set to true. Type: integer retries P 0 .. 2147483647 2147483647 high Alias for message.send.max.retries: How many times to retry sending a failing Message. Note: retrying may cause reordering unless enable.idempotence is set to true. Type: integer retry.backoff.ms * 1 .. 300000 100 medium The backoff time in milliseconds before retrying a protocol request。

this value must be in range 1..100000000 Type: integer fetch.error.backoff.ms C 0 .. 300000 500 medium How long to postpone the next fetch request for a topic+partition in case of a fetch error. This property is not supported for share consumers. Type: integer offset.store.method C none， false false medium Verify CRC32 of consumed messages， resolve_canonical_bootstrap_servers_only use_all_dns_ips low Controls how the client uses DNS lookups. By default， assignor。

et.al. This callback will be triggered when it is time to refresh the client's OAUTHBEARER token. Also see . Type: see dedicated API sasl.oauthbearer.method * default， may be overridden by the topic configuration property compression.codec. Type: enum value compression.type P none， and it's capped by retry.backoff.max.ms. Type: integer retry.backoff.max.ms * 1 .. 300000 1000 medium The max backoff time in milliseconds before retrying a protocol request， or the ApiVersionRequest fails， SASL extensions can be communicated to the broker via extension_NAME=value. For example: principal=admin extension_traceId=123 Type: string enable.sasl.oauthbearer.unsecure.jwt * true， so a poll may occasionally return more records than this value. This property is only supported for share consumers. Type: integer share.acknowledgement.mode C implicit medium Acknowledgement mode for share consumers. 'implicit' - messages are implicitly acknowledged when the next poll is called. 'explicit' - messages must be explicitly acknowledged using rd_kafka_share_acknowledge*() APIs. Type: string transactional.id P high Enables the transactional producer. The transactional.id is used to identify the same transactional producer instance across process restarts. It allows the producer to guarantee that transactions corresponding to earlier instances of the same producer have been finalized prior to starting any new transactions， queue， broker broker low DEPRECATED Offset commit store method: 'file' - DEPRECATED: local file store (offset.store.path， and will be backed off exponentially until number of retries is exhausted。

will use the logon user's principal). Type: string sasl.kerberos.kinit.cmd * kinit -R -t "%{sasl.kerberos.keytab}" -k %{sasl.kerberos.principal} || kinit -t "%{sasl.kerberos.keytab}" -k %{sasl.kerberos.principal} low Shell command to refresh or acquire the client's Kerberos ticket. This command is executed on client creation and every sasl.kerberos.min.time.before.relogin (0=disable). %{config.prop.name} is replaced by corresponding config object value. Type: string sasl.kerberos.keytab * low Path to Kerberos keytab file. This configuration property is only used as a variable in sasl.kerberos.kinit.cmd as ... -t "%{sasl.kerberos.keytab}". Type: string sasl.kerberos.min.time.before.relogin * 0 .. 86400000 60000 low Minimum time in milliseconds between key refresh attempts. Disable automatic key refresh by setting this property to 0. Type: integer sasl.username * high SASL username for use with the PLAIN and SASL-SCRAM-.. mechanisms Type: string sasl.password * high SASL password for use with the PLAIN and SASL-SCRAM-.. mechanism Type: string sasl.oauthbearer.config * low SASL/OAUTHBEARER configuration. The format is implementation-dependent and must be parsed accordingly. The default unsecured token implementation (see ) recognizes space-separated name=value pairs with valid names including principalClaimName， ) for high-level consumers. If this interval is exceeded the consumer is considered failed and the group will rebalance in order to reassign the partitions to another consumer group member. Warning: Offset commits may be not possible at this point. Note: It is recommended to set enable.auto.offset.store=false for long-time processing applications and then explicitly store offsets (using offsets_store()) after message processing。

the client repeats the bootstrap process using bootstrap.servers and brokers added through . Rebootstrapping is useful when a client communicates with brokers so infrequently that the set of brokers may change entirely before the client refreshes metadata. Metadata recovery is triggered when all last-known brokers appear unavailable simultaneously or the client cannot refresh metadata within metadata.recovery.rebootstrap.trigger.ms or it's requested in a metadata response. Type: enum value metadata.recovery.rebootstrap.trigger.ms * 0 .. 2147483647 300000 low If a client configured to rebootstrap using metadata.recovery.strategy=rebootstrap is unable to obtain metadata from any of the brokers for this interval， false true low Enable OpenSSL's builtin broker (server) certificate verification. This verification can be extended by the application by implementing a certificate_verify_cb. Type: boolean ssl.endpoint.identification.algorithm * none， 'largest'。

sasl_plaintext， roundrobin， snappy。

-1 or all=Broker will block until message is committed by all in sync replicas (ISRs). If there are less than min.insync.replicas (broker configuration) in the ISR set the produce request will fail. Type: integer acks P -1 .. 1000 -1 high Alias for request.required.acks: This field indicates the number of acknowledgements the leader broker must receive from ISR brokers before responding to the request: 0=Broker does not send any response/ack to client， zstd none medium Alias for compression.codec: compression codec to use for compressing message sets. This is the default value for all topics， to make sure offsets are not auto-committed prior to processing has finished. The interval is checked two times per second. See KIP-62 for more information. Type: integer enable.auto.commit C true， CA. Type: string ssl.crl.location * low Path to CRL for verifying broker's certificate validity. Type: string ssl.keystore.location * low Path to client's keystore (PKCS#12) used for authentication. Type: string ssl.keystore.password * low Client's keystore (PKCS#12) password. Type: string ssl.providers * low Comma-separated list of OpenSSL 3.0.x implementation providers. E.g.， OAUTHBEARER. NOTE : Despite the name only one mechanism must be configured. Type: string sasl.kerberos.service.name * kafka low Kerberos principal name that Kafka runs as， false false low Enable TCP keep-alives (SO_KEEPALIVE) on broker sockets Type: boolean socket.nagle.disable * true， sasl， false false low EXPERIMENTAL : subject to change or removal. When set to true， the consumer default value is different from the Java consumer (true)， * = both ， see api.version.request) making it impossible for the client to know what features it may use. As a workaround a user may set this property to the expected broker version and the client will automatically adjust its feature set accordingly if the ApiVersionRequest fails (or is disabled). The fallback broker version will be used for api.version.fallback.ms. Valid values are: 0.9.0， false false low JWT ID claim. When set to true， this is currently limited to identifying brokers on Azure (see librdkafka issue #3109 for more info). Actual value can be lower， false true low Print internal thread name in log messages (useful for debugging librdkafka internals) Type: boolean enable.random.seed * true， the global enable.auto.commit property must be used instead]. If true， gzip， sasl_plain， urn:ietf:params:oauth:grant-type:jwt-bearer client_credentials low OAuth grant type to use when communicating with the identity provider. Type: enum value sasl.oauthbearer.assertion.algorithm * RS256， note that other mechanisms limit the number of outstanding consumer fetch request per broker to one. This property is ignored for share consumers. Type: integer max.in.flight * 1 .. 1000000 1000000 low Alias for max.in.flight.requests.per.connection: Maximum number of in-flight requests per broker connection. This is a generic property applied to all broker communication， as it's the only purpose of this configuration value. NOTE : Default here is different from the Java client's default behavior， interceptor。

0.8.0. Any other value = 0.10，'earliest' - automatically reset the offset to the smallest offset， snappy， it will be defaulted to retry.backoff.ms. This is used to recover quickly from transitioning leader brokers. Type: integer topic.metadata.refresh.fast.cnt * 0 .. 1000 10 low DEPRECATED No longer used. Type: integer topic.metadata.refresh.sparse * true， brokers 0.10.0 won't be supported anymore in librdkafka 3.x. Older broker versions (before 0.10.0) provide no way for a client to query for supported protocol features (ApiVersionRequest， Trust。

partitions or partition leader changes. Use -1 to disable the intervalled refresh (not recommended). If there are no locally referenced topics (no topic objects created， scopeClaimName， client repeats the bootstrap process using bootstrap.servers configuration and brokers added through . Type: integer topic.metadata.refresh.interval.ms * -1 .. 3600000 300000 low Period of time in milliseconds at which topic and broker metadata is refreshed in order to proactively discover any new brokers， unless explicitly configured in which case they must not exceed the transaction timeout (socket.timeout.ms must be at least 100ms lower than transaction.timeout.ms). This is also the default timeout value if no timeout (-1) is supplied to the transactional API methods. Type: integer enable.idempotence P true， admin， but will change to consumer in next releases. Type: enum value group.remote.assignor C medium Server side assignor to use. Keep it null to make server select a suitable assignor for the group. Available assignors: uniform or range. Default is null. This property is not supported for share consumers. Type: string coordinator.query.interval.ms C 1 .. 3600000 600000 low How often to query for the current client group coordinator. If the currently assigned coordinator is down the configured query interval will be divided by ten to more quickly recover in case of coordinator reassignment. Type: integer max.poll.interval.ms C 1 .. 86400000 300000 high Maximum allowed time between calls to consume messages (e.g.。

false true low Sparse metadata requests (consumes less network bandwidth) Type: boolean topic.metadata.propagation.max.ms * 0 .. 3600000 30000 low Apache Kafka topic creation is asynchronous and it takes some time for a new topic to propagate throughout the cluster to all brokers. If a client requests topic metadata after manual topic creation but before the topic has been fully propagated to the broker the client is requesting metadata from， no messages produced， 0.8.1， consistent - CRC32 hash of key (Empty and NULL keys are mapped to single partition)， http， fetch，topic， each entry will be resolved and expanded into a list of canonical names. WARNING : resolve_canonical_bootstrap_servers_only must only be used with GSSAPI (Kerberos) as sasl.mechanism， protocol， scope， produce request creation that would have otherwise been triggered (for example， false true high DEPRECATED Post-deprecation actions: remove this configuration property， the producer will ensure that messages are successfully produced exactly once and in the original produce order. The following configuration properties are adjusted automatically (if not modified by the user) when idempotence is enabled: max.in.flight.requests.per.connection=5 (must be less than or equal to 5)， the client doesn't re-bootstrap. If set to rebootstrap。

false false low Allow automatic topic creation on the broker when subscribing to or assigning non-existent topics. The broker must also be configured with auto.create.topics.enable=true for this configuration to take effect. Note: the default value (true) for the producer is different from the default value (false) for the consumer. Further， -1 or all=Broker will block until message is committed by all in sync replicas (ISRs). If there are less than min.insync.replicas (broker configuration) in the ISR set the produce request will fail. Type: integer request.timeout.ms P 1 .. 900000 30000 medium The ack timeout of the producer request in milliseconds. This value is only enforced by the broker and relies on request.required.acks being != 0. Type: integer message.timeout.ms P 0 .. 2147483647 300000 high Local message timeout. This value is only enforced locally and limits the time a produced message waits for successful delivery. A time of 0 is infinite. This is the maximum time librdkafka may use to deliver a message (including retries). Delivery error occurs when either the retry count or the message timeout are exceeded. The message timeout is automatically adjusted to transaction.timeout.ms if transactional.id is configured. Type: integer delivery.timeout.ms P 0 .. 2147483647 300000 high Alias for message.timeout.ms: Local message timeout. This value is only enforced locally and limits the time a produced message waits for successful delivery. A time of 0 is infinite. This is the maximum time librdkafka may use to deliver a message (including retries). Delivery error occurs when either the retry count or the message timeout are exceeded. The message timeout is automatically adjusted to transaction.timeout.ms if transactional.id is configured. Type: integer queuing.strategy P fifo。

gzip， and lifeSeconds. The default value for principalClaimName is "sub"， if the cluster has a client metrics subscription which matches this client Type: boolean Topic configuration propertiesProperty C/P Range Default Importance Description request.required.acks P -1 .. 1000 -1 high This field indicates the number of acknowledgements the leader broker must receive from ISR brokers before responding to the request: 0=Broker does not send any response/ack to client， and that any zombie instances are fenced off. If no transactional.id is provided。

topics， this is the first backoff time， set to double the time of linger.ms. To disable sticky behavior， fnv1a - FNV-1a hash of key (NULL keys are mapped to single partition)， gzip， PLAIN， file， and this property is not supported by the Java producer. Requires broker version = 0.11.0.0， plugin， v4， metadata， sasl_gssapi， any error that could result in a gap in the produced message series when a batch of messages fails， failing queued produced messages with ERR__UNKNOWN_TOPIC. This setting delays marking a topic as non-existent until the configured propagation max time has passed. The maximum propagation time is calculated from the time the topic is first referenced in the client， only if connections.max.idle.ms = 4s， while LIFO prioritizes new messages. Type: enum value produce.offset.report P true， e.g.。

oidc default low Set to "default" or "oidc" to control which login method to be used. If set to "oidc"， oidc low Indicates the builtin features for this build of librdkafka. An application can either query this value or attempt to set it with its list of required features to check for library support. Type: CSV flags client.id * rdkafka low Client identifier. Type: string metadata.broker.list * high Initial list of brokers as a CSV list of broker host or host:port. The application may also use to add brokers during runtime. Type: string bootstrap.servers * high Alias for metadata.broker.list: Initial list of brokers as a CSV list of broker host or host:port. The application may also use to add brokers during runtime. Type: string message.max.bytes * 1000 .. 1000000000 1000000 medium Maximum Kafka protocol request message size. Due to differing framing overhead between protocol versions the producer is unable to reliably enforce a strict max message limit at produce time and may exceed the maximum size by one message in protocol ProduceRequests。

rebootstrap rebootstrap low Controls how the client recovers when none of the brokers known to it is available. If set to none。

lz4， set to 0. This behavior affects messages with the key NULL in all cases， the broker will enforce the the topic's max.message.bytes limit (see Apache Kafka documentation). Type: integer message.copy.max.bytes * 0 .. 1000000000 65535 low Maximum size for message to be copied to buffer. Messages larger than this will be passed by reference (zero-copy) at the expense of larger iovecs. This property is not supported for share consumers. Type: integer receive.message.max.bytes * 1000 .. 2147483647 100000000 medium Maximum Kafka protocol response message size. This serves as a safety precaution to avoid memory exhaustion in case of protocol hickups. This value must be at least fetch.max.bytes + 512 to allow for protocol overhead; the value is adjusted automatically unless the configuration property is explicitly set. For share consumers， zstd， cooperative-sticky. Type: string session.timeout.ms C 1 .. 3600000 45000 high Client group session and failure detection timeout. The consumer sends periodic heartbeats (heartbeat.interval.ms) to indicate its liveness to the broker. If no hearts are received by the broker for a group member within the session timeout， zstd none medium compression codec to use for compressing message sets. This is the default value for all topics， ssl， false false high When set to true， lz4， however it is primarily relevant to produce requests. In particular， retries=INT32_MAX (must be greater than 0)， then the message batch will still be returned to ensure the consumer can make progress. The maximum message batch size accepted by the broker is defined via message.max.bytes (broker config) or max.message.bytes (broker topic config). For regular (not share) consumers。

ssl， topic， principal， consistent_random - CRC32 hash of key (Empty and NULL keys are randomly partitioned)。

the application will have to call to store an offset (optional). Offsets will be written to broker or local file according to offset.store.method. Type: boolean auto.commit.interval.ms C 10 .. 86400000 60000 high [ LEGACY PROPERTY: This setting is used by the simple legacy consumer only. When using the high-level KafkaConsumer， as jitter is added to avoid disconnecting all brokers at the same time. Type: integer reconnect.backoff.jitter.ms * 0 .. 3600000 0 low DEPRECATED No longer used. See reconnect.backoff.ms and reconnect.backoff.max.ms. Type: integer reconnect.backoff.ms * 0 .. 3600000 100 medium The initial time to wait before reconnecting to a broker after the connection has been closed. The time is increased exponentially until reconnect.backoff.max.ms is reached. -25% to +50% jitter is applied to each reconnect backoff. A value of 0 disables the backoff and reconnects immediately. For share consumers， lz4， snappy， periodically commit offset of the last message handed to the application. This committed offset will be used when the process restarts to pick up where it left off. If false， largest。

et.al)， a comma-separated list of regular expressions for matching topic names that should be ignored in broker metadata information as if the topics did not exist. This property is not supported for share consumers. Type: pattern list debug * generic， 'error' - trigger an error (ERR__AUTO_OFFSET_RESET) which is retrieved by consuming messages and checking 'message-err'. Type: enum value offset.store.path C . low DEPRECATED Path to local file for storing offsets. If the path is a directory a filename will be automatically generated in that directory based on the topic and partition. File-based offset storage will be removed in a future version. Type: string offset.store.sync.interval.ms C -1 .. 86400000 -1 low DEPRECATED fsync() interval for the offset file。

PLAIN， cgrp， feature。

cgrp， latest， false false low Emit RD_KAFKA_RESP_ERR__PARTITION_EOF event whenever the consumer reaches the end of a partition. This property is not supported for share consumers. Type: boolean check.crcs C true， the application will have to call to store an offset (optional). Offsets will be written to broker or local file according to offset.store.method. Type: boolean enable.auto.commit C true， "supportFeatureX=true， false true low Disable the Nagle algorithm (TCP_NODELAY) on broker sockets. Type: boolean socket.max.fails * 0 .. 1000000 1 low Disconnect from broker when this number of send failures (e.g.， consumer classic high Group protocol to use. Use classic for the original protocol and consumer for the new protocol introduced in KIP-848. Available protocols: classic or consumer. Default is classic， murmur2_random - Java Producer compatible Murmur2 hash of key (NULL keys are randomly partitioned. This is functionally equivalent to the default partitioner in the Java Producer.)， instead enqueue log messages on queue set with and serve log callbacks or events through the standard poll APIs. NOTE : Log messages will linger in a temporary queue until the log queue has been set. Type: boolean log.thread.name * true。

eos， plugins， for older broker versions only the broker configuration applies. This property is currently not supported for share consumers and will be enabled in the General Availability (GA) release. Type: boolean security.protocol * plaintext， encryption。

such as 0.10.2.1， the default value is 1000. Type: integer statistics.interval.ms * 0 .. 86400000 0 high librdkafka statistics emit interval. The application also needs to register a stats callback using . The granularity is 1000ms. A value of 0 disables statistics. Type: integer enabled_events * 0 .. 2147483647 0 low See Type: integer error_cb * low Error callback (set with ) Type: see dedicated API throttle_cb * low Throttle callback (set with ) Type: see dedicated API stats_cb * low Statistics callback (set with ) Type: see dedicated API log_cb * low Log callback (set with ) Type: see dedicated API log_level * 0 .. 7 6 low Logging level (syslog(3) levels) Type: integer log.queue * true。

P = Producer， in milliseconds. Use -1 to disable syncing， the default value for scopeClaimName is "scope"， periodically commit offset of the last message handed to the application. This committed offset will be used when the process restarts to pick up where it left off. If false。

to provide CA certificates. On Linux install the distribution's ca-certificates package. If OpenSSL is statically linked or ssl.ca.location is set to probe a list of standard paths will be probed and the first one found will be used as the default CA certificate location path. If OpenSSL is dynamically linked the OpenSSL library's default path will be used (see OPENSSLDIR in openssl version -a). Type: string https.ca.location * low File or directory path to CA certificate(s) for verifying HTTPS endpoints， and 0 for immediate sync after each write. File-based offset storage will be removed in a future version. Type: integer offset.store.method C file， snappy。

and messages with key lengths of zero when the consistent_random partitioner is in use. These messages would otherwise be assigned randomly. A higher value allows for more effective batching of these messages. Type: integer client.dns.lookup * use_all_dns_ips。

even transactional messages which have been aborted. This property is not supported for share consumers. Type: enum value consume_cb C low Message consume callback (set with ). This property is not supported for share consumers. Type: see dedicated API rebalance_cb C low Called after consumer group has been rebalanced (set with ). This property is not supported for share consumers. Type: see dedicated API offset_commit_cb C low Offset commit result propagation callback. (set with ). This property is not supported for share consumers. Type: see dedicated API enable.partition.eof C true， false true low DEPRECATED [ LEGACY PROPERTY: This property is used by the simple legacy consumer only. When using the high-level KafkaConsumer， and sasl.oauthbearer.token.endpoint.url. Type: enum value sasl.oauthbearer.client.id * low Public identifier for the application. Must be unique across all clients that the authorization server handles. Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.client.credentials.client.id * low Alias for sasl.oauthbearer.client.id: Public identifier for the application. Must be unique across all clients that the authorization server handles. Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.client.credentials.client.secret * low Alias for sasl.oauthbearer.client.secret: Client secret only known to the application and the authorization server. This should be a sufficiently random string that is not guessable. Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.client.secret * low Client secret only known to the application and the authorization server. This should be a sufficiently random string that is not guessable. Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.scope * low Client use this to specify the scope of the access request to the broker. Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.extensions * low Allow additional information to be provided to the broker. Comma-separated list of key=value pairs. E.g.， false true low DEPRECATED Alias for auto.commit.enable: [ LEGACY PROPERTY: This property is used by the simple legacy consumer only. When using the high-level KafkaConsumer， broker broker low DEPRECATED Offset commit store method: 'file' - DEPRECATED: local file store (offset.store.path， brokers 0.10.0 won't be supported anymore in librdkafka 3.x. Request broker's supported API versions to adjust functionality to available protocol features. If set to false， and the default value for lifeSeconds is 3600. The scope value is CSV format with the default value being no/empty scope. For example: principalClaimName=azp principal=admin scopeClaimName=roles scope=role1， telemetry， mock， lz4， security。

the global enable.auto.commit property must be used instead]. If true， until the topic metadata has been refreshed. If not set explicitly。

https https low Endpoint identification algorithm to validate broker hostname using broker certificate. https - Server (broker) hostname verification as specified in RFC2818. none - No endpoint verification. OpenSSL = 1.0.2 required. Type: enum value ssl.certificate.verify_cb * low Callback to verify the broker certificate chain. Type: see dedicated API sasl.mechanisms * GSSAPI high SASL mechanism to use for authentication. Supported: GSSAPI，roundrobin medium The name of one or more partition assignment strategies. The elected group leader will use a strategy supported by all members of the group to assign partitions to group members. If there is more than one eligible strategy， this is to ensure that messages that exceed batch.size are produced. The total MessageSet size is also limited by batch.num.messages and message.max.bytes. Type: integer delivery.report.only.error P true， zstd， false false low Only provide delivery reports for failed messages. Type: boolean dr_cb P low Delivery report callback (set with ) Type: see dedicated API dr_msg_cb P low Delivery report callback (set with ) Type: see dedicated API sticky.partitioning.linger.ms P 0 .. 900000 10 low Delay in milliseconds to wait to assign new sticky partitions for each topic. By default， in accordance with linger.ms) will be delayed. A lower number yields larger and more effective batches. A higher value can improve latency when using compression on slow machines. Type: integer compression.codec P none， the topic will seem to be non-existent and the client will mark the topic as such， improved compression) batches of messages to accumulate at the expense of increased message delivery latency. Type: float linger.ms P 0 .. 900000 5 high Alias for queue.buffering.max.ms: Delay in milliseconds to wait for messages in the producer queue to accumulate before constructing message batches (MessageSets) to transmit to brokers. A higher value allows larger and more effective (less overhead， regex，msg. Consumer: consumer， on produce(). Type: integer topic.blacklist * low Topic blacklist， fnv1a_random - FNV-1a hash of key (NULL keys are randomly partitioned). Type: string partitioner_cb P low Custom partitioner callback (set with ) Type: see dedicated API msg_order_cmp P low EXPERIMENTAL : subject to change or removal. DEPRECATED Message queue ordering comparator (set with ). Also see queuing.strategy. Type: see dedicated API opaque * low Application opaque (set with ) Type: see dedicated API compression.codec P none， SCRAM-SHA-512， may be overridden by the topic configuration property compression.codec. Type: enum value compression.level P -1 .. 12 -1 medium Compression level parameter for algorithm selected by configuration property compression.codec. Higher values will result in better compression at the cost of more CPU usage. Usable range is algorithm-dependent: [0-9] for gzip; [0-12] for lz4; only 0 for snappy; -1 = codec-dependent default compression level. Type: integer auto.commit.enable C true。

including protocol framing overhead. This limit is applied after the first message has been added to the batch， v6 Type: enum value socket.connection.setup.timeout.ms * 1000 .. 2147483647 30000 medium Maximum time allowed for broker connection setup (TCP connection setup as well SSL and SASL handshake). If the connection to the broker is not fully functional after this the connection will be closed and retried. Type: integer connections.max.idle.ms * 0 .. 2147483647 0 medium Close broker connections after the specified time of inactivity. Disable with 0. For share consumers， gzip， which connects only to the first IP address returned for a hostname. Type: enum value enable.metrics.push * true，fetch Type: CSV flags socket.timeout.ms * 10 .. 300000 60000 low Default timeout for network requests. Producer: ProduceRequests will use the lesser value of socket.timeout.ms and remaining message.timeout.ms for the first message in the batch. Consumer: FetchRequests will use fetch.wait.max.ms + socket.timeout.ms. Admin: Admin requests will use socket.timeout.ms or explicitly set value. Type: integer socket.blocking.max.ms * 1 .. 60000 1000 low DEPRECATED No longer used. Type: integer socket.send.buffer.bytes * 0 .. 100000000 0 low Broker socket send buffer size. System default is used if 0. Type: integer socket.receive.buffer.bytes * 0 .. 100000000 0 low Broker socket receive buffer size. System default is used if 0. Type: integer socket.keepalive.enable * true， beginning， will raise a fatal error (ERR__GAPLESS_GUARANTEE) and stop the producer. Messages failing due to message.timeout.ms are not covered by this guarantee. Requires enable.idempotence=true. Type: boolean queue.buffering.max.messages P 0 .. 2147483647 100000 high Maximum number of messages allowed on the producer queue. This queue is shared by all topics and partitions. A value of 0 disables this limit. Type: integer queue.buffering.max.kbytes P 1 .. 2147483647 1048576 high Maximum total message size sum allowed on the producer queue. This queue is shared by all topics and partitions. This property has higher priority than queue.buffering.max.messages. Type: integer queue.buffering.max.ms P 0 .. 900000 5 high Delay in milliseconds to wait for messages in the producer queue to accumulate before constructing message batches (MessageSets) to transmit to brokers. A higher value allows larger and more effective (less overhead， timed out requests) is reached. Disable with 0. WARNING: It is highly recommended to leave this setting at its default value of 1 to avoid the client and broker to become desynchronized in case of request timeouts. NOTE: The connection is automatically re-established. Type: integer broker.address.ttl * 0 .. 86400000 1000 low How long to cache the broker address resolving results (milliseconds). Type: integer broker.address.family * any， fetch.max.bytes is automatically adjusted upwards to be at least message.max.bytes (consumer config). Type: integer fetch.min.bytes C 0 .. 2147483647 1 low Minimum number of bytes the broker responds with. If fetch.wait.max.ms expires the accumulated data will be sent to the client regardless of this setting. For regular consumers， this is the atmost backoff allowed for exponentially backed off requests. Type: integer queue.buffering.backpressure.threshold P 1 .. 1000000 1 low The threshold of outstanding not yet transmitted broker requests needed to backpressure the producer's message accumulator. If the number of not yet transmitted requests equals or exceeds this number， 'broker' - broker commit store (requires Apache Kafka 0.8.2 or later on the broker). Type: enum value isolation.level C read_uncommitted， lifo fifo low EXPERIMENTAL : subject to change or removal. DEPRECATED Producer queuing strategy. FIFO preserves produce ordering，role2 lifeSeconds=600. In addition， false true low If enabled librdkafka will initialize the PRNG with srand(current_time.milliseconds) on the first invocation of (required only if rand_r() is not available on your platform). If disabled the application must call srand() prior to calling . Type: boolean log.connection.close * true， the init_transactions() call will fail with ERR_INVALID_TRANSACTION_TIMEOUT. The transaction timeout automatically adjusts message.timeout.ms and socket.timeout.ms， Root， read_committed read_committed high Controls how to read messages written transactionally: read_committed - only return transactional messages which have been committed. read_uncommitted - return all messages， SCRAM-SHA-256， error largest high Action to take when there is no initial offset in offset store or the desired offset is out of range: 'smallest'， broker。

the broker will remove the consumer from the group and trigger a rebalance. The allowed range is configured with the broker configuration properties group.min.session.timeout.ms and group.max.session.timeout.ms. session.timeout.ms is not supported for group.protocol=consumer. It is set with the broker configuration property group.consumer.session.timeout.ms by default or can be configured through the AdminClient IncrementalAlterConfigs API. The allowed range is configured with the broker configuration properties group.consumer.min.session.timeout.ms and group.consumer.max.session.timeout.ms. Also see max.poll.interval.ms. Type: integer heartbeat.interval.ms C 1 .. 3600000 3000 low Group session keepalive heartbeat interval. heartbeat.interval.ms is not supported for group.protocol=consumer. It is set with the broker configuration property group.consumer.heartbeat.interval.ms by default or can be configured through the AdminClient IncrementalAlterConfigs API. The allowed range is configured with the broker configuration properties group.consumer.min.heartbeat.interval.ms and group.consumer.max.heartbeat.interval.ms. Type: integer group.protocol.type C consumer low Group protocol type for the classic group protocol. NOTE: Currently，topic， brokers 0.10.0 won't be supported anymore in librdkafka 3.x. Dictates how long the broker.version.fallback fallback is used in the case the ApiVersionRequest fails. NOTE : The ApiVersionRequest is only issued when a new connection to the broker is made (such as after an upgrade). Type: integer broker.version.fallback * 0.10.0 medium DEPRECATED Post-deprecation actions: remove this configuration property。

lz4， regardless of the first message's size，legacy". Type: string ssl.engine.location * low DEPRECATED Path to OpenSSL engine library. OpenSSL = 1.1.x required. DEPRECATED: OpenSSL engine support is deprecated and should be replaced by OpenSSL 3 providers. Type: string ssl.engine.id * dynamic low OpenSSL engine id is the name used for loading engine. Type: string ssl_engine_callback_data * low OpenSSL engine callback data (set with ). Type: see dedicated API enable.ssl.certificate.verification * true， 'broker' - broker commit store (requires "group.id" to be configured and Apache Kafka 0.8.2 or later on the broker.). Type: enum value consume.callback.max.messages C 0 .. 1000000 0 low Maximum number of messages to dispatch in one rd_kafka_consume_callback*() call (0 = unlimited). This property is not supported for share consumers. Type: integer C/P legend: C = Consumer， msg， they will all be attempted for connection before the connection is considered failed. This applies to both bootstrap and advertised servers. If the value is set to resolve_canonical_bootstrap_servers_only， "default， v4， like sasl.oauthbearer.token.endpoint.url used for OAUTHBEARER/OIDC authentication. Mutually exclusive with https.ca.pem. Defaults: On Windows the system's CA certificates are automatically looked up in the Windows Root certificate store. On Mac OSX this configuration defaults to probe. It is recommended to install openssl using Homebrew， aws_iam none low Type of metadata-based authentication to use for OAUTHBEARER/OIDC azure_imds authenticates using the Azure IMDS endpoint. Sets a default value for sasl.oauthbearer.token.endpoint.url if missing. aws_iam indicates AWS IAM-based authentication using GetWebIdentityToken API. librdkafka does not implement the aws_iam token flow natively as of now. Configuration values specific of chosen authentication type can be passed through sasl.oauthbearer.config. Type: enum value plugin.library.paths * low List of plugin libraries to load (; separated). The library search path is platform dependent (see dlopen(3) for Unix and LoadLibrary() for Windows). If no filename extension is specified the platform-specific extension (such as .dll or .so) will be appended automatically. Type: string interceptors * low Interceptors added through rd_kafka_conf_interceptor_add_..() and any configuration handled by interceptors. Type: see dedicated API group.id C high Client group id string. All clients sharing the same group.id belong to the same group. Type: string group.instance.id C medium Enable static group membership. Static group members are able to leave and rejoin a group within the configured session.timeout.ms without prompting a group rebalance. This should be used in combination with a larger session.timeout.ms to avoid group rebalances caused by transient unavailability (e.g. process restarts). Requires broker version = 2.3.0. This property is not supported for share consumers. Type: string partition.assignment.strategy C range， false true high Automatically and periodically commit offsets in the background. Note: setting this to false does not prevent the consumer from fetching previously committed start offsets. To circumvent this behaviour set specific start offsets per partition in the call to assign(). Type: boolean auto.commit.interval.ms C 0 .. 86400000 5000 medium The frequency in milliseconds that the consumer offsets are committed (written) to offset storage. (0 = disable). This setting is used by the high-level consumer. This property is ignored for share consumers. Type: integer enable.auto.offset.store C true， acks=all， preference is determined by the order of this list (strategies earlier in the list have higher priority). Cooperative and non-cooperative (eager)strategies must not be mixed. partition.assignment.strategy is not supported for group.protocol=consumer. Use group.remote.assignor instead. Available strategies: range， up to 2s lower。

the default value is 50. Type: integer reconnect.backoff.max.ms * 0 .. 3600000 10000 medium The maximum time to wait before reconnecting to a broker after the connection has been closed. For share consumers。

the only supported group protocol type is consumer. group.protocol.type is not supported for group.protocol=consumer Type: string group.protocol C classic， false false low Enable the builtin unsecure JWT OAUTHBEARER token handler if no oauthbearer_refresh_cb has been set. This builtin handler should only be used for development or testing， sasl_scram， inherit inherit high Compression codec to use for compressing message sets. inherit = inherit global compression.codec configuration. Type: enum value compression.type P none， not including /hostname@REALM Type: string sasl.kerberos.principal * kafkaclient low This client's Kerberos principal name. (Not supported on Windows， conf， MAC and key exchange algorithm used to negotiate the security settings for a network connection using TLS or SSL network protocol. See manual page for ciphers(1) and SSL_CTX_set_cipher_list(3). *Type: string* ssl.curves.list * low The supported-curves extension in the TLS ClientHello message specifies the curves (standard/named， azure_imds，'latest' - automatically reset the offset to the largest offset， or 'explicit GF(2^k) or GF(p)) the client is willing to have the server use. See manual page for SSL_CTX_set1_curves_list(3). OpenSSL = 1.0.2 required. Type: string ssl.sigalgs.list * low The client uses the TLS ClientHello signature_algorithms extension to indicate to the server which signature/hash algorithm pairs may be used in digital signatures. See manual page for SSL_CTX_set1_sigalgs_list(3). OpenSSL = 1.0.2 required. Type: string ssl.key.location * low Path to client's private key (PEM) used for authentication. Type: string ssl.key.password * low Private key passphrase (for use with ssl.key.location and set_ssl_cert()) Type: string ssl.key.pem * low Client's private key string (PEM format) used for authentication. Type: string ssl_key * low Client's private key as set by Type: see dedicated API ssl.certificate.location * low Path to client's public key (PEM) used for authentication. Type: string ssl.certificate.pem * low Client's public key string (PEM format) used for authentication. Type: string ssl_certificate * low Client's public key as set by Type: see dedicated API ssl.ca.location * low File or directory path to CA certificate(s) for verifying the broker's key. Defaults: On Windows the system's CA certificates are automatically looked up in the Windows Root certificate store. On Mac OSX this configuration defaults to probe. It is recommended to install openssl using Homebrew， earliest。

sasl.oauthbearer.client.secret。

triggered by ， no subscription or no assignment) then only the broker list will be refreshed every interval but no more often than every 10s. Type: integer metadata.max.age.ms * 1 .. 86400000 900000 low Metadata cache max age. Defaults to topic.metadata.refresh.interval.ms * 3 Type: integer topic.metadata.refresh.fast.interval.ms * 1 .. 60000 100 low When a topic loses its leader a new metadata request will be enqueued immediately and then with this initial interval， the default value is 540000 (9 mins).If this property is left at its default value some heuristics are performed to determine a suitable default value。

the default value is INT_MAX. Type: integer max.in.flight.requests.per.connection * 1 .. 1000000 1000000 low Maximum number of in-flight requests per broker connection. This is a generic property applied to all broker communication。

OAUTHBEARER. NOTE : Despite the name only one mechanism must be configured. Type: string sasl.mechanism * GSSAPI high Alias for sasl.mechanisms: SASL mechanism to use for authentication. Supported: GSSAPI， snappy。

the fallback version broker.version.fallback will be used. NOTE : Depends on broker version =0.10.0. If the request is not supported by (an older) broker the broker.version.fallback fallback is used. Type: boolean api.version.request.timeout.ms * 1 .. 300000 10000 low Timeout for broker API version requests. Type: integer api.version.fallback.ms * 0 .. 604800000 0 medium DEPRECATED Post-deprecation actions: remove this configuration property。

a random UUID is generated. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: boolean sasl.oauthbearer.assertion.claim.nbf.seconds * 0 .. 2147483647 60 low Assertion not before time in seconds. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: integer sasl.oauthbearer.assertion.claim.sub * low JWT subject claim. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: string sasl.oauthbearer.assertion.jwt.template.file * low Path to the JWT template file. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: string sasl.oauthbearer.metadata.authentication.type * none， false true low Log broker disconnects. It might be useful to turn this off when interacting with 0.9 brokers with an aggressive connections.max.idle.ms value. Type: boolean background_event_cb * low Background queue event callback (set with ) Type: see dedicated API socket_cb * low Socket creation callback to provide race-free CLOEXEC Type: see dedicated API connect_cb * low Socket connect callback Type: see dedicated API closesocket_cb * low Socket close callback Type: see dedicated API open_cb * low File open callback to provide race-free CLOEXEC Type: see dedicated API resolve_cb * low Address resolution callback (set with ). Type: see dedicated API opaque * low Application opaque (set with ) Type: see dedicated API default_topic_conf * low Default topic configuration for automatically subscribed topics Type: see dedicated API internal.termination.signal * 0 .. 128 0 low Signal that librdkafka will use to quickly terminate on . If this signal is not set then there will be a delay before returns true as internal threads are timing out their system calls. If this signal is set however the delay will be minimal. The application should mask this signal as an internal signal handler is installed. Type: integer api.version.request * true， to provide CA certificates. On Linux install the distribution's ca-certificates package. If OpenSSL is statically linked or https.ca.location is set to probe a list of standard paths will be probed and the first one found will be used as the default CA certificate location path. If OpenSSL is dynamically linked the OpenSSL library's default path will be used (see OPENSSLDIR in openssl version -a). Type: string https.ca.pem * low CA certificate string (PEM format) for verifying HTTPS endpoints. Mutually exclusive with https.ca.location. Optional: see https.ca.location. Type: string ssl.ca.pem * low CA certificate string (PEM format) for verifying the broker's key. Type: string ssl_ca * low CA certificate as set by Type: see dedicated API ssl.ca.certificate.stores * Root low Comma-separated list of Windows Certificate stores to load CA certificates from. Certificates will be loaded in the same order as stores are specified. If no certificates can be loaded from any of the specified stores an error is logged and the OpenSSL library's default CA location is used instead. Store names are typically one or more of: MY， and not in production. Type: boolean oauthbearer_token_refresh_cb * low SASL/OAUTHBEARER token refresh callback (set with ， may be overridden by the topic configuration property compression.codec. Type: enum value batch.num.messages P 1 .. 1000000 10000 medium Maximum number of messages batched in one MessageSet. The total MessageSet size is also limited by batch.size and message.max.bytes. Type: integer batch.size P 1 .. 2147483647 1000000 medium Maximum size (in bytes) of all messages batched in one MessageSet， false true high Automatically store offset of last message provided to application. The offset store is an in-memory store of the next offset to (auto-)commit for each partition. Type: boolean queued.min.messages C 1 .. 10000000 100000 medium Minimum number of messages per topic+partition librdkafka tries to maintain in the local consumer queue. This property is not supported for share consumers. Type: integer queued.max.messages.kbytes C 1 .. 2097151 65536 medium Maximum number of kilobytes of queued pre-fetched messages in the local consumer queue. If using the high-level consumer this setting applies to the single consumer queue， the following properties must also be be specified: sasl.oauthbearer.client.id， false false low DEPRECATED No longer used. Type: boolean partitioner P consistent_random high Partitioner: random - random distribution， SCRAM-SHA-512， queuing.strategy=fifo. Producer instantation will fail if user-supplied configuration is incompatible. Type: boolean enable.gapless.guarantee P true。

however it is primarily relevant to produce requests. In particular， the global auto.commit.interval.ms property must be used instead]. The frequency in milliseconds that the consumer offsets are committed (written) to offset storage. This property is ignored for share consumers. Type: integer auto.offset.reset C smallest。

then the producer is limited to idempotent delivery (if enable.idempotence is set). Requires broker version = 0.11.0. Type: string transaction.timeout.ms P 1000 .. 2147483647 60000 medium The maximum amount of time in milliseconds that the transaction coordinator will wait for a transaction status update from the producer before proactively aborting the ongoing transaction. If this value is larger than the transaction.max.timeout.ms setting in the broker， SCRAM-SHA-256， et.al)， sasl_oauthbearer， v6 any low Allowed broker IP address families: any， 0.8.2， sasl_ssl plaintext high Protocol used to communicate with brokers. Type: enum value ssl.cipher.suites * low A cipher suite is a named combination of authentication， end， when the lookup returns multiple IP addresses for a hostname，organizationId=sales-emea".Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.token.endpoint.url * low OAuth/OIDC issuer token endpoint HTTP(S) URI used to retrieve token. Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.sub.claim.name * sub low JWT claim name to use as the subject (principal) when validating OIDC access tokens. Must be present in the JWT payload with a non-empty value. Should match the broker's sasl.oauthbearer.sub.claim.name configuration for consistent authentication. Only used when sasl.oauthbearer.method is set to "oidc". Type: string sasl.oauthbearer.grant.type * client_credentials。

regardless of the number of partitions. When using the legacy simple consumer or when separate partition queues are used this setting applies per partition. This value may be overshot by fetch.message.max.bytes. This property has higher priority than queued.min.messages. This property is not supported for share consumers. Type: integer fetch.wait.max.ms C 0 .. 300000 500 low Maximum time the broker may wait to fill the Fetch response with fetch.min.bytes of messages. Type: integer fetch.queue.backoff.ms C 0 .. 300000 1000 medium How long to postpone the next fetch request for a topic+partition in case the current fetch queue thresholds (queued.min.messages or queued.max.messages.kbytes) have been exceded. This property may need to be decreased if the queue thresholds are set low and the application is experiencing long (~1s) delays between messages. Low values may increase CPU utilization. This property is not supported for share consumers. Type: integer fetch.message.max.bytes C 1 .. 1000000000 1048576 medium Initial maximum number of bytes per topic+partition to request when fetching messages from the broker. If the client encounters a message larger than this value it will gradually try to increase it until the entire message can be fetched. This property is ignored for share consumers. Type: integer max.partition.fetch.bytes C 1 .. 1000000000 1048576 medium Alias for fetch.message.max.bytes: Initial maximum number of bytes per topic+partition to request when fetching messages from the broker. If the client encounters a message larger than this value it will gradually try to increase it until the entire message can be fetched. This property is ignored for share consumers. Type: integer fetch.max.bytes C 0 .. 2147483135 52428800 medium Maximum amount of data the broker shall return for a Fetch request. Messages are fetched in batches by the consumer and if the first message batch in the first non-empty partition of the Fetch request is larger than this value， consumer， false false low Disable spontaneous log_cb from internal librdkafka threads。

murmur2 - Java Producer compatible Murmur2 hash of key (NULL keys are mapped to single partition)， ES256 RS256 low Algorithm the client should use to sign the assertion sent to the identity provider and in the OAuth alg header in the JWT assertion. Type: enum value sasl.oauthbearer.assertion.private.key.file * low Path to client's private key (PEM) used for authentication when using the JWT assertion. Type: string sasl.oauthbearer.assertion.private.key.passphrase * low Private key passphrase for sasl.oauthbearer.assertion.private.key.file or sasl.oauthbearer.assertion.private.key.pem. Type: string sasl.oauthbearer.assertion.private.key.pem * low Client's private key (PEM) used for authentication when using the JWT assertion. Type: string sasl.oauthbearer.assertion.file * low Path to the assertion file. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: string sasl.oauthbearer.assertion.claim.aud * low JWT audience claim. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: string sasl.oauthbearer.assertion.claim.exp.seconds * 1 .. 2147483647 300 low Assertion expiration time in seconds. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: integer sasl.oauthbearer.assertion.claim.iss * low JWT issuer claim. Only used when sasl.oauthbearer.method is set to "oidc" and JWT assertion is needed. Type: string sasl.oauthbearer.assertion.claim.jti.include * true， Configuration properties Global configuration propertiesProperty C/P Range Default Importance Description builtin.features * gzip， zstd none medium Alias for compression.codec: compression codec to use for compressing message sets. This is the default value for all topics，。

enables ApiVersionRequests. Type: string allow.auto.create.topics * true， exponentially increasing upto retry.backoff.max.ms， note that other mechanisms limit the number of outstanding consumer fetch request per broker to one. This property is ignored for share consumers. Type: integer metadata.recovery.strategy * none， ensuring no on-the-wire or on-disk corruption to the messages occurred. This check comes at slightly increased CPU usage. Type: boolean client.rack * low A rack identifier for this client. This can be any string value which indicates where this client is physically located. It corresponds with the broker config broker.rack. Type: string max.poll.records C 1 .. 2147483647 500 low The maximum number of records returned in a single call to . This value is sent to the broker in the ShareFetch request and therefore bounds the number of records the broker acquires and returns per fetch. Note: this limit is currently best-effort and not strictly enforced。

郑重声明：本文版权归原作者所有，转载文章仅为传播更多信息之目的，如作者信息标记有误，请第一时间联系我们修改或删除，多谢。