- centos7.6
- kafka集群
未搭建kafka集群的请移步参考搭建
常用命令说明：所有的执行命令均默认表示在kafka的安装目录，如果在bin目录下直接执行sh的命令即可
Topic# 查看节点下topic列表 bin/kafka-topics.sh --list --zookeeper node1:2181 bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181 # 创建topic test01 bin/kafka-topics.sh --create --zookeeper node1:2181,node2:2181,node3:2181 --replication-factor 2 --partitions 2 --topic test01 # 删除对应的topic test01 bin/kafka-topics.sh --delete --zookeeper node1:2181,node2:2181,node3:2181 --topic test01
topic创建、删除和列表查看效果展示：
# 在topic test01下创建生产者 bin/kafka-console-producer.sh --broker-list node1:9092,node2:9092,node3:9092 --topic test01 # 在topic test01下创建消费者 bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --topic test01
生产者和消费者效果展示：
