kafka 配置详解（kafka慢慢学之三配置篇）

• 3.配置
• [3.1 代理配置](https://kafka.apache.org/documentation/#brokerconfigs)
• [3.2 TOPIC config主题级配置](https://kafka.apache.org/documentation/#topicconfigs)
• [3.3 生产者配置](https://kafka.apache.org/documentation/#producerconfigs)
• [3.3 生产者配置](https://kafka.apache.org/documentation/#producerconfigs)
• [3.4 消费者配置](https://kafka.apache.org/documentation/#consumerconfigs)
• [3.5 Kafka 连接配置](https://kafka.apache.org/documentation/#connectconfigs)
• [3.6 Kafka 流配置](https://kafka.apache.org/documentation/#streamsconfigs)
• [3.7 管理员配置](https://kafka.apache.org/documentation/#adminclientconfigs)

基本配置如下：

• broker.id
• log.dirs
• zookeeper.connect

Topic-level configurations and defaults are discussed in more detail below.

• advertised.listenerslisteners如果与配置属性不同，则发布到 ZooKeeper 以供客户端使用的侦听器。在 IaaS 环境中，这可能需要与代理绑定的接口不同。如果未设置，listeners将使用 for 的值。与 不同listeners的是，通告 0.0.0.0 元地址是无效的。与 不同listeners的是，此属性中可以有重复的端口，因此可以将一个侦听器配置为通告另一个侦听器的地址。这在使用外部负载平衡器的某些情况下很有用。Type:stringDefault:nullValid Values:Importance:highUpdate Mode:per-broker
• auto.create.topics.enable在服务器上启用自动创建主题Type:booleanDefault:trueValid Values:Importance:highUpdate Mode:read-only
• auto.leader.rebalance.enableEnables auto leader balancing. A background thread checks the distribution of partition leaders at regular intervals, configurable by leader.imbalance.check.interval.seconds. If the leader imbalance exceeds leader.imbalance.per.broker.percentage, leader rebalance to the preferred leader for partitions is triggered.Type:booleanDefault:trueValid Values:Importance:highUpdate Mode:read-only
• [[background.threads]用于各种后台处理任务的线程数Type:intDefault:10Valid Values:[1,...]Importance:highUpdate Mode:cluster-wide
• broker.id
• 此服务器的代理 ID。如果未设置，将生成一个唯一的代理 id。为避免 zookeeper 生成的代理 id 和用户配置的代理 id 发生冲突，生成的代理 id 从 reserved.broker.max.id 1 开始。
• Type:intDefault:-1Valid Values:Importance:highUpdate Mode:read-only
• compression.type指定给定主题的最终压缩Type。此配置接受标准压缩编解码器（'gzip'、'snappy'、'lz4'、'zstd'）。它还接受相当于不压缩的“未压缩”；和“生产者”，这意味着保留生产者设置的原始压缩编解码器。Type:stringDefault:producerValid Values:Importance:highUpdate Mode:cluster-wide
• control.plane.listener.name用于控制器和代理之间通信的侦听器名称。Broker 将使用 control.plane.listener.name 来定位侦听器列表中的端点，以侦听来自控制器的连接。Type:booleanDefault:trueValid Values:Importance:highUpdate Mode:read-only

与主题相关的配置既有服务器default值，也有可选的每个主题覆盖。如果没有给出每个主题的配置，则使用服务器default值。可以在创建主题时通过提供一个或多个--config选项来设置覆盖。此示例创建一个名为my-topic 的主题，具有自定义的最大消息大小和刷新率：

> bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic my-topic --partitions 1 \ --replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1

也可以稍后使用 alter configs 命令更改或设置覆盖。此示例更新my-topic的最大消息大小：

> bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic --alter --add-config max.message.bytes=128000

要检查在主题上设置的覆盖，您可以执行

> bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic --describe

To remove an override you can do

> bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic --alter --delete-config max.message.bytes

以下是主题级别的配置。该属性的服务器default配置在“服务器default属性”标题下给出。给定的服务器default配置值仅适用于没有显式主题配置覆盖的主题。

• cleanup.policy 清理策略
• “删除”或“压缩”或两者兼有的字符串。此字符串指定要在旧日志段上使用的保留策略。当达到保留时间或大小限制时，default策略（“删除”）将丢弃旧段。“compact”设置将启用主题的日志压缩。Type:listDefault:deleteValid Values:[compact, delete]Server Default Property:log.cleanup.policyImportance:mediumcompression.typeSpecify the final compression type for a given topic. This configuration accepts the standard compression codecs ('gzip', 'snappy', 'lz4', 'zstd'). It additionally accepts 'uncompressed' which is equivalent to no compression; and 'producer' which means retain the original compression codec set by the producer.Type:stringDefault:producerValid Values:[uncompressed, zstd, lz4, snappy, gzip, producer]Server Default Property:compression.typeImportance:medium
• delete.retention.ms为日志压缩主题保留删除墓碑标记的时间量。如果消费者从偏移量 0 开始，此设置还规定了消费者必须完成读取的时间，以确保他们获得最终阶段的有效快照（否则可能会在完成扫描之前收集删除墓碑）。Type:longDefault:86400000 (1 day)Valid Values:[0,...]Server Default Property:log.cleaner.delete.retention.msImportance:medium
• file.delete.delay.ms从文件系统中删除文件之前的等待时间Type:longDefault:60000 (1 minute)Valid Values:[0,...]Server Default Property:log.segment.delete.delay.msImportance:medium
• flush.messages此设置允许指定我们将强制将数据写入日志的 fsync 的时间间隔。例如，如果将其设置为 1，我们将在每条消息后进行 fsync；如果是 5，我们将在每 5 条消息后进行 fsync。一般来说，我们建议您不要设置此选项并使用复制来提高持久性，并允许操作系统的后台刷新功能，因为它更有效。可以基于每个主题覆盖此设置（请参阅每个主题配置部分).Type:longDefault:9223372036854775807Valid Values:[0,...]Server Default Property:log.flush.interval.messagesImportance:medium
• flush.ms此设置允许指定一个时间间隔，在该时间间隔内我们将强制将数据 fsync 写入日志。例如，如果将其设置为 1000，我们将在 1000 毫秒后进行 fsync。一般来说，我们建议您不要设置此选项并使用复制来提高持久性，并允许操作系统的后台刷新功能，因为它更有效。Type:longDefault:9223372036854775807Valid Values:[0,...]Server Default Property:log.flush.interval.msImportance:medium3.3 生产者配置Below is the configuration of the producer:
• key.serializer实现org.apache.kafka.common.serialization.Serializer接口的键的序列化程序类。Type:classDefault:Valid Values:Importance:high
• value.serializer实现org.apache.kafka.common.serialization.Serializer接口的值的序列化器类。Type:classDefault:Valid Values:Importance:high
• 引导服务器用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用所有服务器，无论此处指定哪些服务器进行引导——此列表仅影响用于发现完整服务器集的初始主机。此列表应采用host1:port1,host2:port2,.... 由于这些服务器仅用于初始连接以发现完整的集群成员（可能会动态更改），因此此列表不需要包含完整的服务器集（但您可能需要多个服务器，以防服务器停机） .Type:listDefault:""Valid Values:non-null stringImportance:high
• 缓冲内存The total bytes of memory the producer can use to buffer records waiting to be sent to the server. If records are sent faster than they can be delivered to the server the producer will block for max.block.ms after which it will throw an exception.此设置应大致对应于生产者将使用的总内存，但不是硬性限制，因为并非生产者使用的所有内存都用于缓冲。一些额外的内存将用于压缩（如果启用压缩）以及维护正在进行的请求。Type:longDefault:33554432Valid Values:[0,...]Importance:high
• 压缩TypeThe compression type for all data generated by the producer. The default is none (i.e. no compression). Valid values are none, gzip, snappy, lz4, or zstd. Compression is of full batches of data, so the efficacy of batching will also impact the compression ratio (more batching means better compression).Type：Stringdefault：没有任何value：Importance：high
• 重试设置大于零的值将导致客户端重新发送发送失败并可能出现暂时性错误的任何记录。请注意，此重试与客户端在收到错误后重新发送记录没有什么不同。delivery.timeout.ms如果配置的超时时间在成功确认之前先过期，则生产请求将在重试次数用完之前失败。用户通常应该更喜欢不设置此配置，而是使用它delivery.timeout.ms来控制重试行为。开启幂等需要此配置值大于 0。如果设置了冲突的配置并且幂等未显式启用，则幂等被禁用。enable.idempotence设置为false和时允许重试max.in.flight.requests.per.connection to 1 will potentially change the ordering of records because if two batches are sent to a single partition, and the first fails and is retried but the second succeeds, then the records in the second batch may appear first.Type：intdefault：2147483647value：[0,...,2147483647]Importance：high
• ssl.key.password密钥存储文件中的私钥或“ssl.keystore.key”中指定的 PEM 密钥的password。仅当配置了双向身份验证时，客户端才需要这样做。Type:passworddefault：noneValid Values:Importance：high
• ssl.keystore.certificate.chain'ssl.keystore.type' 指定格式的证书链。default SSL 引擎工厂仅支持带有 X.509 证书列表的 PEM 格式Type：passworddefault：noneValid Values:Importance：high
• ssl.keystore.key'ssl.keystore.type' 指定格式的私钥。default SSL 引擎工厂仅支持带有 PKCS#8 密钥的 PEM 格式。如果密钥已加密，则必须使用“ssl.key.password”指定密钥passwordType：passworddefault：nonevalue：Importance:high
• ssl.keystore.location密钥存储文件的位置。这对于客户端是可选的，可用于客户端的双向身份验证。Type：StringDefault:nonevalue：Importance:high
• ssl.keystore.password密钥存储文件的存储password。这对于客户端是可选的，并且仅在配置了“ssl.keystore.location”时才需要。PEM 格式不支持密钥库password。Type：passwordDefault:nonevalue：Importance:high

Below is the configuration of the producer:

• key.serializer实现org.apache.kafka.common.serialization.Serializer接口的键的序列化程序类。Type:班级default：value：Importance:：high
• value.serializer实现org.apache.kafka.common.serialization.Serializer接口的值的序列化器类。Type：班级default：value：Importance:：highbootstrap.servers用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用所有服务器，无论此处指定哪些服务器进行引导——此列表仅影响用于发现完整服务器集的初始主机。此列表应采用host1:port1,host2:port2,.... 由于这些服务器仅用于初始连接以发现完整的集群成员（可能会动态更改），因此此列表不需要包含完整的服务器集（但您可能需要多个服务器，以防服务器停机） .Type：列表default：""value：非空字符串Importance:highbuffer.memoryThe total bytes of memory the producer can use to buffer records waiting to be sent to the server. If records are sent faster than they can be delivered to the server the producer will block for max.block.ms after which it will throw an exception.此设置应大致对应于生产者将使用的总内存，但不是硬性限制，因为并非生产者使用的所有内存都用于缓冲。一些额外的内存将用于压缩（如果启用压缩）以及维护正在进行的请求。Type：LongDefault:33554432value：[0,...]Importance:highcompression.typeThe compression type for all data generated by the producer. The default is none (i.e. no compression). Valid values are none, gzip, snappy, lz4, or zstd. Compression is of full batches of data, so the efficacy of batching will also impact the compression ratio (more batching means better compression).Type：Stringdefault：没有任何value：Importance:：high
• retry设置大于零的值将导致客户端重新发送发送失败并可能出现暂时性错误的任何记录。请注意，此重试与客户端在收到错误后重新发送记录没有什么不同。delivery.timeout.ms如果配置的超时时间在成功确认之前先过期，则生产请求将在重试次数用完之前失败。用户通常应该更喜欢不设置此配置，而是使用它delivery.timeout.ms来控制重试行为。开启幂等需要此配置值大于 0。如果设置了冲突的配置并且幂等未显式启用，则幂等被禁用。enable.idempotence设置为false和时允许重试max.in.flight.requests.per.connection to 1 will potentially change the ordering of records because if two batches are sent to a single partition, and the first fails and is retried but the second succeeds, then the records in the second batch may appear first.Type：intdefault：2147483647value：[0,...,2147483647]Importance:：high
• ssl.key.password密钥存储文件中的私钥或“ssl.keystore.key”中指定的 PEM 密钥的password。仅当配置了双向身份验证时，客户端才需要这样做。Type:passworddefault：“”Valid Values:Importance:：high
• ssl.keystore.certificate.chain'ssl.keystore.type' 指定格式的证书链。default SSL 引擎工厂仅支持带有 X.509 证书列表的 PEM 格式Type：passworddefault：“”Valid Values:Importance:：high
• ssl.keystore.key'ssl.keystore.type' 指定格式的私钥。default SSL 引擎工厂仅支持带有 PKCS#8 密钥的 PEM 格式。如果密钥已加密，则必须使用“ssl.key.password”指定密钥passwordType：passworddefault：“”value：Importance:high
• ssl.keystore.location密钥存储文件的位置。这对于客户端是可选的，可用于客户端的双向身份验证。Type：StringDefault:“”value：Importance:high
• ssl.keystore.password密钥存储文件的存储password。这对于客户端是可选的，并且仅在配置了“ssl.keystore.location”时才需要。PEM 格式不支持密钥库password。Type：passwordDefault:“”value：Importance:high

下面是消费者的配置：

• key.deserializer实现org.apache.kafka.common.serialization.Deserializer接口的键的反序列化器类。Type：班级Default：Valid Values:Importance：high
• value.deserializer实现org.apache.kafka.common.serialization.Deserializer接口的值的反序列化器类。Type：班级Default:value：Importance：highbootstrap.servers用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用所有服务器，无论此处指定哪些服务器进行引导——此列表仅影响用于发现完整服务器集的初始主机。此列表应采用host1:port1,host2:port2,.... 由于这些服务器仅用于初始连接以发现完整的集群成员（可能会动态更改），因此此列表不需要包含完整的服务器集（但您可能需要多个服务器，以防服务器停机） .Type：listDefault：“”value：非空字符串Importance：high
• fetch.min.bytes服务器应为获取请求返回的最小数据量。如果可用数据不足，则请求将在响应请求之前等待累积那么多数据。1 字节的Default设置意味着只要有一个字节的数据可用或获取请求超时等待数据到达，就会响应获取请求。将此设置为大于 1 的值将导致服务器等待大量数据累积，这可以以一些额外的延迟为代价提高服务器吞吐量。Type：整数Default：1Valid Values:[0,...]Importance：high
• group.id标识此消费者所属的消费者组的唯一字符串。subscribe(topic)如果消费者通过 using或基于 Kafka 的偏移管理策略使用组管理功能，则需要此属性。Type：StringDefault:“”value：Importance：high
• heartbeat.interval.ms使用 Kafka 的组管理设施时，与消费者协调器之间的心跳之间的预期时间。心跳用于确保消费者的会话保持活跃，并在新消费者加入或离开组时促进重新平衡。该值必须设置为低于session.timeout.ms，但通常应设置为不高于该值的 1/3。它可以调整得更低，以控制正常重新平衡的预期时间。Type:整数Default：3000（3 秒）value：Importance:high
• max.partition.fetch.bytes服务器将返回的每个分区的最大数据量。记录由消费者分批获取。如果 fetch 的第一个非空分区中的第一个记录批大于此限制，则该批仍将返回以确保消费者可以进行。代理接受的最大记录批量大小是通过message.max.bytes（代理配置）或max.message.bytes（主题配置）定义的。有关限制消费者请求大小的信息，请参阅 fetch.max.bytes。Type：整数Default:1048576（1 兆字节）value：[0,...]Importance：high
• session.timeout.ms使用 Kafka 的组管理工具时用于检测客户端故障的超时。客户端定期发送心跳以向代理指示其活跃性。如果在此会话超时到期之前代理未收到任何心跳，则代理将从组中删除此客户端并启动重新平衡。请注意，该值必须在代理配置中由group.min.session.timeout.ms和配置的允许范围内group.max.session.timeout.ms。Type:整数Default：45000（45 秒）value：Importance：high
• ssl.key.password密钥存储文件中的私钥或“ssl.keystore.key”中指定的 PEM 密钥的password。仅当配置了双向身份验证时，客户端才需要这样做。Type：passwordDefault：“”value：Importance:high
• ssl.keystore.certificate.chainCertificate chain in the format specified by 'ssl.keystore.type'. Default SSL engine factory supports only PEM format with a list of X.509 certificatesType：passwordDefault：“”value：Importance：high
• ssl.keystore.key'ssl.keystore.type' 指定格式的私钥。Default SSL 引擎工厂仅支持带有 PKCS#8 密钥的 PEM 格式。如果密钥已加密，则必须使用“ssl.key.password”指定密钥passwordType：passwordDefault：“”value：Importance：high

下面是 Kafka Connect 框架的配置。

• config.storage.topic存储连接器配置的 Kafka 主题的名称Type：StringDefault：Valid Values:Importance：high
• [group.id]一个唯一的字符串，用于标识此工作人员所属的 Connect 集群组。Type：StringDefault：value：Importance：highkey.converterConverter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the keys in messages written to or read from Kafka, and since this is independent of connectors it allows any connector to work with any serialization format. Examples of common formats include JSON and Avro.Type：班级Default：Valid Values:Importance：high
• offset.storage.topicThe name of the Kafka topic where connector offsets are storedType：StringDefault：value：Importance：high
• 状态.存储.主题存储连接器和任务状态的 Kafka 主题的名称Type：StringDefault：value：Importance：high
• 值转换器转换器类用于在 Kafka Connect 格式和写入 Kafka 的序列化格式之间进行转换。这控制了写入或读取 Kafka 的消息中值的格式，并且由于它独立于连接器，它允许任何连接器使用任何序列化格式。常见格式的示例包括 JSON 和 Avro。Type：班级Default：value：Importance：highbootstrap.servers用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用所有服务器，无论此处指定哪些服务器进行引导——此列表仅影响用于发现完整服务器集的初始主机。此列表应采用host1:port1,host2:port2,.... 由于这些服务器仅用于初始连接以发现完整的集群成员（可能会动态更改），因此此列表不需要包含完整的服务器集（但您可能需要多个服务器，以防服务器停机） .Type：列表Default：本地主机：9092value：Importance：high
• heartbeat.interval.ms使用 Kafka 的组管理设施时，与组协调器之间的心跳之间的预期时间。心跳用于确保工作人员的会话保持活动状态，并在新成员加入或离开组时促进重新平衡。该值必须设置为低于session.timeout.ms，但通常应设置为不高于该值的 1/3。它可以调整得更低，以控制正常重新平衡的预期时间。Type：整数Default：3000（3 秒）value：Importance:high
• rebalance.timeout.ms重新平衡开始后每个工作人员加入组的最大允许时间。这基本上是对所有任务刷新任何未决数据和提交偏移所需的时间量的限制。如果超过了超时时间，那么worker会被从组中移除，这会导致offset commit失败。Type:整数Default：60000（1 分钟）value：Importance：high
• session.timeout.ms用于检测工作程序故障的超时。工作人员定期发送心跳以向代理指示其活跃性。如果在此会话超时到期之前代理没有收到心跳，那么代理将从组中删除工作人员并启动重新平衡。请注意，该值必须在代理配置中由group.min.session.timeout.ms和配置的允许范围内group.max.session.timeout.ms。Type：整数Default：10000（10 秒）Valid Values:Importance：high
• ssl.key.passwordThe password of the private key in the key store file or the PEM key specified in `ssl.keystore.key'. This is required for clients only if two-way authentication is configured.Type：passwordDefault：“”value：Importance：high
• ssl.keystore.certificate.chain'ssl.keystore.type' 指定格式的证书链。Default SSL 引擎工厂仅支持带有 X.509 证书列表的 PEM 格式Type：passwordDefault：“”value：Importance：high

下面是 Kafka Streams 客户端库的配置。

• application.id
• 流处理应用程序的标识符。在 Kafka 集群中必须是唯一的。它用作 1) Default客户端 ID 前缀，2) 用于成员管理的组 ID，3) 变更日志主题前缀。Type：StringDefault：value：Importance：high
• bootstrap.servers

用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用所有服务器，无论此处指定哪些服务器进行引导——此列表仅影响用于发现完整服务器集的初始主机。此列表应采用host1:port1,host2:port2,.... 由于这些服务器仅用于初始连接以发现完整的集群成员（可能会动态更改），因此此列表不需要包含完整的服务器集（但您可能需要多个服务器，以防服务器停机） .

Type：列表Default：Valid Values:Importance：high

• num.standby.replicas每个任务的备用副本数。Type：intDefault：0value：Importance：high
• state.dir
• 状态存储的目录位置。对于共享相同底层文件系统的每个流实例，此路径必须是唯一的。Type：StringDefault：/var/folders/ds/dq10m26j2kjcypywn_lt0b0m0000gn/T//kafka-streamsvalue：Importance:high
• 状态存储的目录位置。对于共享相同底层文件系统的每个流实例，此路径必须是唯一的。
• Type：StringDefault：/var/folders/ds/dq10m26j2kjcypywn_lt0b0m0000gn/T//kafka-streamsvalue：Importance:high
• acceptable.recovery.lag
• 客户端被认为已赶上以接收活动任务分配的最大可接受滞后（要赶上的偏移量）。分配后，它仍会在处理之前恢复其余的更改日志。为避免在重新平衡期间暂停处理，此配置应对应于给定工作负载的恢复时间远低于一分钟。必须至少为 0。Type：LongDefault:10000value：[0,...]Importance：MID
• 客户端被认为已赶上以接收活动任务分配的最大可接受滞后（要赶上的偏移量）。分配后，它仍会在处理之前恢复其余的更改日志。为避免在重新平衡期间暂停处理，此配置应对应于给定工作负载的恢复时间远低于一分钟。必须至少为 0。
• Type：LongDefault:10000value：[0,...]Importance：MID
• 缓存.max.bytes.buffering用于跨所有线程缓冲的最大内存字节数Type：LongDefault：10485760value：[0,...]Importance：MID
• client.id用于内部消费者、生产者和恢复消费者的客户端 ID 的 ID 前缀字符串，模式为 '-StreamThread--'。Type：StringDefault:“”value：Importance：MID
• default.deserialization.exception.handlerorg.apache.kafka.streams.errors.DeserializationExceptionHandler实现接口的异常处理类。Type：班级Default：org.apache.kafka.streams.errors.LogAndFailExceptionHandlervalue：Importance:MID
• default.key.serde实现org.apache.kafka.common.serialization.Serde接口的键的Default序列化器/反序列化器类。请注意，当使用窗口化 serde 类时，还需要设置org.apache.kafka.common.serialization.Serde通过 'default.windowed.key.serde.inner' 或 'default.windowed.value.serde.inner' 实现接口的内部 serde 类Type：班级Default:“”value：Importance：MID

下面是 Kafka Admin 客户端库的配置。

• bootstrap.servers
• 用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用所有服务器，无论此处指定哪些服务器进行引导——此列表仅影响用于发现完整服务器集的初始主机。此列表应采用host1:port1,host2:port2,.... 由于这些服务器仅用于初始连接以发现完整的集群成员（可能会动态更改），因此此列表不需要包含完整的服务器集（但您可能需要多个服务器，以防服务器停机） .Type：列表Default：value：Importance：high
• ssl.key.password密钥存储文件中的私钥或“ssl.keystore.key”中指定的 PEM 密钥的password。仅当配置了双向身份验证时，客户端才需要这样做。Type：passwordDefault：“”value：Importance：high
• ssl.keystore.certificate.chain'ssl.keystore.type' 指定格式的证书链。Default SSL 引擎工厂仅支持带有 X.509 证书列表的 PEM 格式Type：passwordDefault：“”value：Importance：high
• ssl.keystore.key'ssl.keystore.type' 指定格式的私钥。Default SSL 引擎工厂仅支持带有 PKCS#8 密钥的 PEM 格式。如果密钥已加密，则必须使用“ssl.key.password”指定密钥passwordType：passwordDefault：“”value：Importance：high
• ssl.keystore.location密钥存储文件的位置。这对于客户端是可选的，可用于客户端的双向身份验证。Type：StringDefault：“”value：Importance：high
• ssl.keystore.password密钥存储文件的存储password。这对于客户端是可选的，并且仅在配置了“ssl.keystore.location”时才需要。PEM 格式不支持密钥库password。Type:passwordDefault：“”value：Importance：high
• ssl.truststore.certificates'ssl.truststore.type' 指定格式的受信任证书。Default SSL 引擎工厂仅支持带有 X.509 证书的 PEM 格式。Type：passwordDefault：“”value：Importance：high
• ssl.truststore.location信任库文件的位置。Type：StringDefault：“”value：Importance：high
• ssl.truststore.password信任库文件的password。如果未设置password，仍将使用配置的信任库文件，但禁用完整性检查。PEM 格式不支持信任库password。Type：passwordDefault：“”value：Importance：high
• 客户端.dns.lookup控制客户端如何使用 DNS 查找。如果设置为use_all_dns_ips，则依次连接到每个返回的 IP 地址，直到建立成功的连接。断开连接后，使用下一个 IP。一旦所有 IP 都被使用过一次，客户端会再次从主机名解析 IP（然而，JVM 和操作系统都会缓存 DNS 名称查找）。如果设置为resolve_canonical_bootstrap_servers_only，则将每个引导地址解析为规范名称列表。在引导阶段之后，它的行为与use_all_dns_ips.Type：StringDefault：use_all_dns_ipsvalue：[use_all_dns_ips，resolve_canonical_bootstrap_servers_only]Importance：MID
• client.id
• 发出请求时传递给服务器的 id 字符串。这样做的目的是通过允许将逻辑应用程序名称包含在服务器端请求日志中来跟踪请求的来源，而不仅仅是 ip/port。Type：StringDefault：“”value：Importance：MID
• 发出请求时传递给服务器的 id 字符串。这样做的目的是通过允许将逻辑应用程序名称包含在服务器端请求日志中来跟踪请求的来源，而不仅仅是 ip/port。
• Type：StringDefault：“”value：Importance：MID
• connections.max.idle.ms
• Close idle connections after the number of milliseconds specified by this config.Type：LongDefault：300000（5 分钟）value：Importance：medium
• Close idle connections after the number of milliseconds specified by this config.
• Type：LongDefault：300000（5 分钟）value：Importance：medium