apache-kafka - 卡夫卡 ISR 缩小且不扩展
问题描述
我有一个由 3 个节点组成的 Kafka 集群,每个节点有 1 个 ZK 和 1 个 Broker。
Kafka version 0.10.1.1.
每个主题都有replication-factor=3
和min.insync.replicas=2
。此后我们通过发布检查--describe
主题是否已使用正确的replication-factor
和成功创建ISR
。
一段时间后,我可以看到一些主题将其 ISR 缩小为单一领导者。
/opt/kafka/bin/kafka-topics.sh --describe --zookeeper zk1:2181,zk2:2181,zk3:2181 --topic topic1
Topic:topic1 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: topic1 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
/opt/kafka/bin/kafka-topics.sh --describe --zookeeper zk1:2181,zk2:2181,zk3:2181 --topic topic2
Topic:topic2 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: topic2 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
当我连接到zk Shell
. 我可以看到所有节点都已启动并且controller
在broker:2
/opt/kafka/bin/zookeeper-shell.sh --describe --zookeeper zk1:2181,zk2:2181,zk3:2181
ls /brokers/ids
[0,1,2]
get /controller
{"version":1,"brokerid":2,"timestamp":"1531740996571"}
即使我尝试重新启动代理(仅代理或与动物园管理员一起),主题也不会扩展。
任何建议都非常感谢!
解决方案
推荐阅读
- r - 如何导出叶节点(rpart)的标准偏差?
- php - PHP 致命错误:在第 140 行的 C:\xampp\htdocs\vendor\symfony\process\Pipes\WindowsPipes.php 中超过了 60 秒的最大执行时间
- c - 带 DMA 的 STM32F4 PWM 输入模式。无法测量占空比
- c# - 如何在 Visual Studio Code 中为大型 C# 文件启用语法突出显示?
- python - Python:在出现“页面不存在”错误时避免下载 html
- javascript - ReactJS 样式组件
- java - 如何注入可选
仅当文件存在时? - azure-devops - 使用一个构建定义 VSTS 构建多个项目/存储库
- java - 如何检查其他类方法中的 JButton[3][3] 文本值?
- python - 用于选择数据的 Pandas 源