创建主题
[root@spark01 kafka_2.12-0.10.2.0]# kafka-topics.sh --create --zookeeper spark01:2181,spark02:2181,spark03:2181 --replication-factor 3 --partitions 3 --topic test
其中
–topic 定义topic名
–replication-factor 定义副本数
–partitions 定义分区数
查看一下文件存储的地方
这里不是log日志存储的位置,是文件存储的位置
查看主题
[root@spark01 kafka_2.12-0.10.2.0]# kafka-topics.sh --list --zookeeper spark01:2181,spark02:2181,spark03:2181
删除主题
需要在server.properties配置文件中加入这个信息
否则zookeeper中的数据不会删除,那就得进入zookeeper中将数据删除
发送消息
[root@spark01 kafka_2.12-0.10.2.0]# kafka-console-producer.sh --broker-list spark01:9092,spark02:9092,spark03:9092 --topic test
启动消费者并观察
在其他的机子上启动
[root@spark02 kafka_2.12-0.10.2.0]# kafka-console-consumer.sh --zookeeper spark01:2181,spark02:2181,spark03:2181 --topic test
想要查看以往的数据的需要添加--from-beginning
查看主题信息
[root@spark02 kafka_2.12-0.10.2.0]# kafka-topics.sh --describe --zookeeper spark01:2181,spark02:2181,spark03:2181 –topic test
