kafka 学习（三）创建topic收发消息

创建topic

下来，我们将创建一个主题（topic）,来测试消息饿发送与接收

创建topic,我们得保证zookeeper,和kafka的终端不被关闭，然后打开新的终端，

执行命令

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --topic test --partitions 1 --replication-factor 1

创建成功如图

查看topic

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

可以看到新创建的topic

发送消息

kafka提供了脚本工具，可以在终端发送消息

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

输入命令，按回车，进入如图所示的命令交互式界面

按下回车，消息，就会被发送，

若30秒没有错误出现，通常表明消息发送成功了

消费消息

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning