【大数据基础知识】Kafka集群安装与和测试如何操作

(3)显示topic的详细信息

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

Topic:test PartitionCount:1 ReplicationFactor:3 Configs:

Topic: test Partition: 0 Leader: 1 Replicas: 1,2,0 Isr: 1,2,0

第一行是所有分区的一个整体描述，然后下面列出每个分期的信息，每个分区对应一行。因为本例中只有一个分区，所以下面只有一行。

leader：负责读写消息，zookeeper从所有节点中随机选择leader。

replicas：，列出所有的副本节点，即便节点现在不在服务中。

isr：列出正在服务中的节点。

在本例中，节点1是作为leader运行。

(4)使用客户端命令去发送消息

bin/kafka-console-producer.sh --broker-list node1:9092,node2:9092,node3:9092 --topic test

(5)使用客户端命令去消费消息

bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --from-beginning --topic test

可以通过参数 consumer-property来指定消费者的group id：

kafka-console-consumer.sh --topic test --bootstrap-server node1:9092,node2:9092,node3:9092 --consumer-property group.id=xx

(6)测试集群容错能力

Kill -9 pid[leader节点]

此时，另外一个节点被选做了leader, in-sync 副本列表中不再有节点1：

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

Topic:test PartitionCount:1 ReplicationFactor:3 Configs:

Topic: test Partition: 0 Leader: 2 Replicas: 1,2,0 Isr: 2,0

虽然最初负责读写消息的leader 不在线了，但之前的消息仍然可以消费：

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic test

(7)删除主题

bin/kafka-topics.sh --delete --zookeeper node1:2181,node2:2181,node3:2181 --topic test