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 有任何问题欢迎随时联系或者在文章下方留言哦