Kafka生产与消费

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