kafka-demo

介绍

问题

1， kafka 三个节点，三副本， 一个节点关闭，可以收到消息， 消费时关闭节点消息丢失问题
节点挂了，貌似还可以接受消息，很奇怪

参数

1. 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. xxxx
2. xxxx
3. xxxx

参与贡献

1. https://www.orchome.com/kafka/news

特技

一，主题相关命令： ①创建，查看 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

4. bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 向主题中写入内容
5. bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning 消费消息
6. bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list 消费组
7. bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group group-1 消费情况 很重要的命令