以下命令均在Kafka根目录下执行,zookeeper服务地址:localhost:2181
- 启动kafka服务
- 前台启动
bin/kafka-server-start.sh config/server.properties
- 后台启动
bin/kafka-server-start.sh -daemon config/server.properties
- 停止kafka服务
bin/kafka-server-stop.sh
- 创建Kafka Topic,有两个分区(partitions ),每个分区3个副本
# --replication-factor 3 三个备份,replication-factor(topic副本)个数不能超过broker(服务器)的个数
# --partitions 2 分区数,如果希望消息队列有序的话,partitions 必须为1
# --topic test-topic,topic名字为test-topic
bin/kafka-topics.sh --zookeeper localhost:2181 --create --partitions 2 --replication-factor 3 --topic test-topic
- 查看所有主题列表
bin/kafka-topics.sh --zookeeper localhots:2181 --list
- 查看所有主题的详细信息
bin/kafka-topics.sh --zookeeper localhost:2181 --describe
- 查看指定主题的详细信息
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test-topic
- 删除一个主题
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test-topic