A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始





测试方法:

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


2 个回复

倒序浏览
欢迎有问题及时和学姐联系,DKA-2018
回复 使用道具 举报
感谢分享~~
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马