Brokers类型配置
模块
|
配置项
|
作用域
|
备注
|
---|---|---|---|
DynamicConnectionQuota |
max.connections |
All brokers或brokerId |
服务端最大连接数限制 客户端每个ip最大连接数限制 客户端每个具体ip最大连接数量限制,格式为:100.127.0.0.1:200,100,127.0.0.2:200,... |
DynamicListenerConfig |
Listener configs SSL configs principal.builder.class SASL configs |
All brokers或brokerId | |
DynamicLogConfig |
log.segment.bytes (segment.bytes) |
All brokers或brokerId |
log.segment.bytes (segment.bytes) log.segment.bytes为brokers类型配置 segment.bytes为topics类型配置,其他同理 |
DynamicLogCleaner |
log.cleaner.threads |
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 |
All brokers或brokerId |
新线程池数量公式: newValue > oldValue / 2 && newValue <= oldValue * 2 当指定线程池数量大于运行时,就会创建扩容,当小于时,就会销毁收缩 |
DynamicReplicationQuota |
leader.replication.throttled.rate |
仅用于brokerId |
限制leader副本端处理FETCH请求的每秒流量上限,单位为bytes/sec,表示最高为xxx bytes/sec |
最新文章
- 大数据系统之监控系统(二)Flume的扩展
- 一个ubuntu phper的自我修养(workbench)
- nginx.conf 解释
- SQL EXEC 命令用法
- Windows Azure Table storage 之 动态Table类 DynamicTableEntity
- 最长上升子序列(LIS)模板
- JAVA-环境部分
- N皇后回溯解法 leetcode N-Queens
- 学习C++ Primer 的个人理解(十)
- asp.net各种获取客户端ip方法
- 智能路由——ESB
- 探索Android中的Parcel机制(上)
- QT5 动态链接库的创建和使用(QT自己做动态库给自己使用)
- 在代理中托管特殊方法的python代码实现
- 扩充表字段长度,引发的意外KILLED/ROLLBACK
- Swap Nodes in Pairs(交换节点)
- 解决:Using where; Using join buffer (Block Nested Loop)
- python服务器文件上传下载+GUI【tkinter】
- 阿里云Logtail 快速诊断工具
- Python os.md