黑马程序员技术交流社区

标题: kafka发送消息的三种方式 [打印本页]

---

作者: 梦缠绕的时候    时间: 2019-6-13 16:58
标题: kafka发送消息的三种方式




测试方法：

MAC下操作指令：

1、创建主题：

./kafka-topics.sh --create --topic kafka-study --zookeeper 127.0.0.1:2181 --config max.message.bytes=12800000 --config flush.messages=1 --partitions 5 --replication-factor 1

2、运行上述程序，执行定时任务

3、查看消费情况

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic kafka-study --from-beginning

windows操作指令：

1、进入  D:\zookeeper-3.4.14\bin   打开新的cmd，输入“zkServer“，运行Zookeeper
2、进入 D:\kafka_2.11-0.11.0.0 运行cmd
  .\bin\windows\kafka-server-start.bat .\config\server.properties
3、 创建主题，
    进入D:\kafka_2.11-0.11.0.0运行cmd，输入：
    .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    查看已创建主题：
    .\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
    查看指定主题的详细信息：
    .\bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic test
    查看主题消费详情：
    .\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic kafka-study --from-beginning

---------------------
原文：https://blog.csdn.net/zxc19854/article/details/91400396
有任何问题欢迎随时联系或者在文章下方留言哦

---

作者: 梦缠绕的时候    时间: 2019-6-13 16:58
欢迎有问题及时和学姐联系，DKA-2018

---

作者: 晨大喵    时间: 2019-7-17 13:07
感谢分享~~

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2