二、Kafka 快速入门-linux命令行操作

这就是为了让你熟悉下kafka命令行的使用，实际情况下，不会这样用的

1）查看当前kafka服务器中的所有主题

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --list

2）创建 topic

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --create --replication-factor 1 --partitions 1 --topic first

选项说明：

--topic 定义 topic 名

--replication-factor 定义副本数

--partitions 定义分区数

查看相应的数据存放的文件夹：

3）删除 topic

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --delete --topic first

4)查看某个主题的详情

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --describe --topic first

5）修改分区数

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --alter --topic first --partitions 6

6）发送消息

./kafka-console-producer.sh --broker-list 192.168.3.25:9092 --topic first

7）消费消息

./kafka-console-consumer.sh --zookeeper 192.168.3.25:2181 --topic first --from-beginning

(以上命令不在使用)

./kafka-console-consumer.sh --bootstrap-server 192.168.3.25:9092--from-beginning --topic first