在“Mac配置kafka时遇到的各种问题二”那篇文章中,kafka已经正确安装并且可以启动,下面就要学习一下kafka该怎么使用了。
在分别启动了zookeeper和kafka之后,我们接下来可以创建一个话题:
1.话题topic的创建
1.1 创建新话题my_test
另起窗口,进入解压目录
cd /usr/local/etc/kafka_2.11-2.3.0(这个我还是按之前的路径来的)
接下来输入创建话题指令:
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my_test
(注: partitions指定topic分区数,replication-factor(本条语句中没有)指定topic每个分区的副本数)
如果成功的话,界面会出现:
Created topic my_test.
此时我们就成功创建了话题my_test
1.2 查看topic
还是在这个终端下输入指令:
bin/kafka-topics.sh --list --zookeeper localhost:2181
显示:my_test
到这里,topic就已经创建完成了
2.接下来,我们尝试来创建生产者(producer)
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my_test
3.创建消费者(consumer)
另外打开一个终端,cd到解压文件,再执行下列语句:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_test --from-beginning
这之后,再创建生产者的终端中任意输入一些字符(如:hello world)在消费者的终端中也会出现该段字符。
以上就可以实现生产者到消费者的数据传递
网友评论