1.创建自定义的topic

在bin目录下执行：

sh kafka-topics.sh --create --zookeeper hadoop01:2181 --replication-factor 1 --partitions 1 --topic enbook

SRE实战 互联网时代守护先锋，助力企业售后服务体系运筹帷幄！一键直达领取阿里云限量特价优惠。

注:副本数量要小于等于节点数量

2.查看所有的topic

执行：sh kafka-topics.sh --list --zookeeper hadoop01:2181

3.启动producer

执行：

sh kafka-console-producer.sh --broker-list hadoop01:9092,hadoop02:9092,hadoop03:9092  --topic  enbook

4.启动consumer

执行：

sh kafka-console-consumer.sh --zookeeper hadoop01:2181 --topic enbook --from-beginning

5.可以通过producer和consumer模拟消息的发送和接收

 

6.删除topic指令：

进入bin目录，执行：

sh kafka-topics.sh --delete --zookeeper hadoop01:2181 --topic  enbook

扫码关注我们
微信号：SRE实战
拒绝背锅 运筹帷幄