kafka 主要 *** 作命令

前言

kafka工作流程为：

生产者 -> broker集群 -> 消费者

特性：

1.一台服务器可以装多个broker，通常一台就装一个
2.brokerid必须唯一
3.broker下有 主题 分区

主题 topic 1.创建主题分区

bin/kafka-topics.sh --bootstrap-server brokerName:9092 --create --topic test --partitions 1 --replication-factor 3

2.查看主题列表

bin/kafka-topics.sh --bootstrap-server brokerName:9092 --list 

3.删除主题

bin/kafka-topics.sh --bootstrap-server brokerName:9092  --topic test --describe

生产者

发送数据

bin/kafka-console-producer.sh.sh --broker-list brokerName:9092 --topic test 

消费者

kafka-console-consumer.sh --bootstrap-server brokerName:9092 --topic test --from-beginning