1, kafka 三个节点,三副本, 一个节点关闭,可以收到消息, 消费时关闭节点消息丢失问题
节点挂了,貌似还可以接受消息,很奇怪
broker 参数 min.insync.replicas 其中比较难理解的是min.insync.replicas,这个参数表示ISR集合中的最少副本数,默认值是1,并只有在acks=all或-1时才有效。
acks与min.insync.replicas搭配使用,才能为消息提供最高的持久性保证。
我们知道leader副本默认就包含在ISR中,如果ISR中只有1个副本,acks=all也就相当于acks=1了,引入min.insync.replicas的目的就是为了保证下限:不能只满足于ISR全部写入,还要保证ISR中的写入个数不少于min.insync.replicas。
常见的场景是创建一个三副本(即replication.factor=3)的topic,最少同步副本数设为2(即min.insync.replicas=2),acks设为all,以保证最高的消息持久性。
一,主题相关命令: ①创建,查看 1. bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list 查看topic 2. bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --create --topic test --partitions 3 --replication-factor 3 创建topic 3分区,3副本 3. bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --describe --topic passive 查看主题详细信息 4, bin/kafka-topics.sh --bootstrap-server broker_host:port --describe 查询所有主题的详细数据 ②修改 1, bin/kafka-topics.sh --bootstrap-server broker_host:port --alter --topic <topic_name> --partitions < 新分区数 > // 修改主题分区 2, bin/kafka-configs.sh --zookeeper zookeeper_host:port --entity-type topics --entity-name <topic_name> --alter --add-config max.message.bytes=10485760
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。