美文网首页计算机系列
Mac配置kafka时遇到的各种问题三——kafka基础操作(创

Mac配置kafka时遇到的各种问题三——kafka基础操作(创

作者: 混世魔王也得学计算机 | 来源:发表于2019-07-16 10:08 被阅读0次

    “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)在消费者的终端中也会出现该段字符。

    以上就可以实现生产者到消费者的数据传递

    相关文章

      网友评论

        本文标题:Mac配置kafka时遇到的各种问题三——kafka基础操作(创

        本文链接:https://www.haomeiwen.com/subject/aqzakctx.html