1. 创建主题
[root@localhost bin]# ./kafka-topics.sh --zookeeper 192.168.10.100:2181/kafka,192.168.10.101:2181/kafka,192.168.10.102:2181/kafka --create --topic topic-demo --replication-factor 3 --partitions 4 Error while executing topic command : Replication factor: 3 larger than available brokers: 1. [2022-05-03 22:24:45,039] ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 3 larger than available brokers: 1. (kafka.admin.TopicCommand$) [root@localhost bin]# ./kafka-topics.sh --zookeeper 192.168.10.100:2181/kafka,192.168.10.101:2181/kafka,192.168.10.102:2181/kafka --create --topic topic-demo --replication-factor 1 --partitions 4 Created topic topic-demo.
2. 展示主题信息
[root@localhost bin]# ./kafka-topics.sh --zookeeper 192.168.10.100:2181/kafka,192.168.10.101:2181/kafka,192.168.10.102:2181/kafka --describe --topic topic-demo Topic: topic-demo TopicId: 8cia5U7QTXmPWPNEzDCvLA PartitionCount: 4 ReplicationFactor: 1 Configs: Topic: topic-demo Partition: 0 Leader: 0 Replicas: 0 Isr: 0 Topic: topic-demo Partition: 1 Leader: 0 Replicas: 0 Isr: 0 Topic: topic-demo Partition: 2 Leader: 0 Replicas: 0 Isr: 0 Topic: topic-demo Partition: 3 Leader: 0 Replicas: 0 Isr: 0
3. 订阅主题
[root@localhost bin]# ./kafka-console-consumer.sh --bootstrap-server 192.168.10.101:9092 --topic topic-demo
4. 发送消息
[root@localhost bin]# ./kafka-console-producer.sh --broker-list 192.168.10.101:9092 --topic topic-demo >hello kafka >
消费者消费消息：
[root@localhost bin]# ./kafka-console-consumer.sh --bootstrap-server 192.168.10.101:9092 --topic topic-demo hello kafka
