测试方法：

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

欢迎有问题及时和学姐联系，DKA-2018

感谢分享~~