kafka-clients之CommonClientConfigs
CommonClientConfigs是kafka-clients库中一个包含Kafka通用配置项的类，它界说了Kafka Producer、Consumer、Admin等客户端共享的配置。以下是其中的重要配置项及其含义：1. bootstrap.servers
[*]类型：List<String>
[*]阐明：Kafka集群的地址列表。可以是多个节点的地址，以逗号分隔，如localhost:9092,localhost:9093。客户端通过这些地址连接到Kafka集群。
2. client.id
[*]类型：String
[*]阐明：客户端ID，用于标识Kafka客户端的名称。Kafka会在日记和监控中记录该ID，帮助运维人员辨认是哪个客户端在发送或消费消息。
3. connections.max.idle.ms
[*]类型：Long
[*]默认值：540000（9分钟）
[*]阐明：Kafka客户端与服务器之间的连接最大空闲时间。凌驾该时间后，客户端会关闭空闲连接，以节约资源。
4. metadata.max.age.ms
[*]类型：Long
[*]默认值：300000（5分钟）
[*]阐明：客户端缓存元数据（比如分区信息）的最大时间。凌驾该时间后，客户端会向Kafka集群重新哀求元数据。
5. metric.reporters
[*]类型：List<String>
[*]阐明：配置用于度量陈诉的类名列表。可以将自界说的度量陈诉器参加这里，将客户端的度量数据上报到外部系统。
6. metrics.num.samples
[*]类型：Integer
[*]默认值：2
[*]阐明：Kafka客户端的度量数据的采样数，用于计算度量指标的均匀值。
7. metrics.recording.level
[*]类型：String
[*]默认值：INFO
[*]阐明：控制Kafka客户端的度量记录级别。可选值有INFO（记录核心指标）和DEBUG（记录所有指标，数据量更大）。
8. metrics.sample.window.ms
[*]类型：Long
[*]默认值：30000（30秒）
[*]阐明：度量数据的时间窗口，用于计算统计数据。客户端会基于此时间窗口对度量数据举行统计分析。
9. receive.buffer.bytes
[*]类型：Integer
[*]默认值：65536（64KB）
[*]阐明：TCP接收缓冲区的巨细。设置较大的缓冲区可以提高网络吞吐量，但会消耗更多内存资源。
10. reconnect.backoff.ms
[*]类型：Long
[*]默认值：50
[*]阐明：当连接失败时，Kafka客户端实验重连的初始等候时间。每次连接失败后，等候时间会按指数增长。
[*]规则：org.apache.kafka.common.utils.ExponentialBackoff
11. reconnect.backoff.max.ms
[*]类型：Long
[*]默认值：1000
[*]阐明：客户端重试连接的最大等候时间。用于限定重连等候时间的增长上限，克制重连间隔过长。
12. request.timeout.ms
[*]类型：Integer
[*]默认值：30000（30秒）
[*]阐明：客户端哀求的超时时间。凌驾该时间后，如果哀求没有相应，客户端会抛出超时非常。
13. retry.backoff.ms
[*]类型：Long
[*]默认值：100
[*]阐明：重试的时间间隔。客户端在哀求失败后会按照该间隔时间重试利用。
14. security.protocol
[*]类型：String
[*]默认值：PLAINTEXT
[*]阐明：指定客户端与Kafka集群之间的安全协议。常用的协议有PLAINTEXT（无加密）、SSL（SSL加密）、SASL_PLAINTEXT（认证但不加密）和SASL_SSL（认证并加密）。
15. send.buffer.bytes
[*]类型：Integer
[*]默认值：131072（128KB）
[*]阐明：TCP发送缓冲区的巨细。可以通过增大该值来提高发送的吞吐量。
16. socket.connection.setup.timeout.ms
[*]类型：Long
[*]默认值：10000（10秒）
[*]阐明：创建连接的超时时间，凌驾该时间后，连接将被关闭。适用于需要快速连接或资源有限的环境。
17. socket.connection.setup.timeout.max.ms
[*]类型：Long
[*]默认值：30000（30秒）
[*]阐明：创建连接的最大超时时间，凌驾此时间则连接失败。与 socket.connection.setup.timeout.ms 共同利用，限定连接的最长等候时间。
18. sasl.mechanism
[*]类型：String
[*]默认值：GSSAPI
[*]阐明：设置SASL的认证机制，如GSSAPI、PLAIN、SCRAM-SHA-256、SCRAM-SHA-512等，共同security.protocol用于认证。
19. ssl.endpoint.identification.algorithm
[*]类型：String
[*]默认值：https
[*]阐明：用于SSL连接的端点辨认算法，确保客户端连接的是精确的服务器。设置为空字符串可禁用此验证。
20. ssl.key.password, ssl.keystore.location, ssl.keystore.password
[*]类型：String
[*]阐明：SSL认证所需的配置项，分别对应SSL私钥暗码、Keystore文件位置和Keystore文件暗码。
21. ssl.truststore.location, ssl.truststore.password
[*]类型：String
[*]阐明：SSL连接中信任库的配置项，分别对应Truststore文件位置和Truststore文件暗码，用于客户端验证服务器的身份。
这些配置项通常在需要细粒度控制客户端行为时举行调解。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]