kafka项目常见使用

kafka项目常见使用 创建Kafka主题设置分区副本

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 5 --topic carEnter

启动Kafka

./bin/kafka-server-start.sh -daemon config/server.properties

查看主题列表

./bin/kafka-topics.sh --list --zookeeper localhost:2181

查看某个主题

./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic carEnter

删除主题

./bin/kafka-topics --delete --topic carEnter --zookeeper localhost:2181