模块
配置项
作用域
备注

DynamicConnectionQuota

max.connections
max.connections.per.ip
max.connections.per.ip.overrides

All brokers或brokerId

服务端最大连接数限制

客户端每个ip最大连接数限制

客户端每个具体ip最大连接数量限制,格式为:100.127.0.0.1:200,100,127.0.0.2:200,...

DynamicListenerConfig

Listener configs
listeners
advertised.listeners
listener.security.protocol.map

SSL configs

principal.builder.class
ssl.protocol
ssl.provider
ssl.cipher.suites
ssl.enabled.protocols
ssl.keystore.type
ssl.keystore.location
ssl.keystore.password
ssl.key.password
ssl.truststore.type
ssl.truststore.location
ssl.truststore.password
ssl.keymanager.algorithm
ssl.trustmanager.algorithm
ssl.endpoint.identification.algorithm
ssl.secure.random.implementation
ssl.client.auth

SASL configs
sasl.mechanism.inter.broker.protocol
sasl.jaas.config
sasl.enabled.mechanisms
sasl.kerberos.service.name
sasl.kerberos.kinit.cmd
sasl.kerberos.ticket.renew.window.factor
sasl.kerberos.ticket.renew.jitter
sasl.kerberos.min.time.before.relogin
sasl.kerberos.principal.to.local.rules
sasl.login.refresh.window.factor
sasl.login.refresh.window.jitter
sasl.login.refresh.min.period.seconds
sasl.login.refresh.buffer.seconds

All brokers或brokerId  
DynamicLogConfig

log.segment.bytes (segment.bytes)
log.roll.ms, log.roll.hours (segment.ms)
log.roll.jitter.ms, log.roll.jitter.hours (segment.jitter.ms)
log.index.size.max.bytes (segment.index.bytes)
log.flush.interval.messages (flush.messages)
log.flush.interval.ms (flush.ms)
log.retention.bytes (retention.bytes)
log.retention.ms, log.retention.minutes, log.retention.hours (retention.ms)
message.max.bytes(max.message.bytes)
log.index.interval.bytes (index.interval.bytes)
log.cleaner.delete.retention.ms (delete.retention.ms)
log.cleaner.min.compaction.lag.ms (min.compaction.lag.ms)
log.cleaner.min.cleanable.ratio (min.cleanable.dirty.ratio)
log.cleanup.policy (cleanup.policy)
log.segment.delete.delay.ms (file.delete.delay.ms)
unclean.leader.election.enable (unclean.leader.election.enable)
min.insync.replicas (min.insync.replicas)
max.message.bytes (max.message.bytes)
compression.type (compression.type)
log.preallocate (preallocate)
log.message.timestamp.type (message.timestamp.type)
log.message.timestamp.difference.max.ms (message.timestamp.difference.max.ms)
log.message.downconversion.enable(message.downconversion.enable)

All brokers或brokerId

log.segment.bytes (segment.bytes)

log.segment.bytes为brokers类型配置

segment.bytes为topics类型配置,其他同理

DynamicLogCleaner

log.cleaner.threads
log.cleaner.dedupe.buffer.size
log.cleaner.io.buffer.load.factor
log.cleaner.io.buffer.size
log.cleaner.io.max.bytes.per.second
log.cleaner.backoff.ms

All brokers或brokerId  
DynamicMetricsReporters metric.reporters All brokers或brokerId

Kafka提供了Metrics Reporter的插件扩展功能,默认提供了JmxReporter实现,也即我们已经可以通过JMX工具来查看Kafka的Metrics。所以我们可以自己实现一套Metrics Reporter(实现org.apache.kafka.common.metrics.MetricsReporter),来自定义获取这些Metrics。

DynamicThreadPool

num.io.threads
num.network.threads
num.replica.fetchers
num.recovery.threads.per.data.dir
background.threads

All brokers或brokerId

新线程池数量公式:

newValue > oldValue / 2 && newValue <= oldValue * 2

当指定线程池数量大于运行时,就会创建扩容,当小于时,就会销毁收缩

DynamicReplicationQuota

leader.replication.throttled.rate
follower.replication.throttled.rate
replica.alter.log.dirs.io.max.bytes.per.second

仅用于brokerId

限制leader副本端处理FETCH请求的每秒流量上限,单位为bytes/sec,表示最高为xxx bytes/sec
限制follower副本发送FETCH请求的每秒流量上限,单位为bytes/sec,表示最高为xxx bytes/sec
限制磁盘内目录之间拷贝迁移每秒流量上限,单位bytes/sec,表示最高为xxx bytes/sec

最新文章

  1. 大数据系统之监控系统(二)Flume的扩展
  2. 一个ubuntu phper的自我修养(workbench)
  3. nginx.conf 解释
  4. SQL EXEC 命令用法
  5. Windows Azure Table storage 之 动态Table类 DynamicTableEntity
  6. 最长上升子序列(LIS)模板
  7. JAVA-环境部分
  8. N皇后回溯解法 leetcode N-Queens
  9. 学习C++ Primer 的个人理解(十)
  10. asp.net各种获取客户端ip方法
  11. 智能路由——ESB
  12. 探索Android中的Parcel机制(上)
  13. QT5 动态链接库的创建和使用(QT自己做动态库给自己使用)
  14. 在代理中托管特殊方法的python代码实现
  15. 扩充表字段长度,引发的意外KILLED/ROLLBACK
  16. Swap Nodes in Pairs(交换节点)
  17. 解决:Using where; Using join buffer (Block Nested Loop)
  18. python服务器文件上传下载+GUI【tkinter】
  19. 阿里云Logtail 快速诊断工具
  20. Python os.md

热门文章

  1. SpringJDBC的使用(转载)
  2. CentOS 下 maven 安装
  3. 20191121-3 Final阶段贡献分配规则
  4. Java提供的JDBC标准- 六大步骤
  5. 调用微软未公开ZwQueryInformationThread函数根据线程句柄获取线程ID
  6. $Noip2016/Luogu2827$蚯蚓
  7. ECShop二次开发指南(一)
  8. Python基础复习面向对象篇
  9. matlab数组相除
  10. Project Settings之Quality翻译