kafka

消息中间件
启动过程
先启动zookeeper
zkServer.cmd
然后kafka的服务 要在bin目录下，就是能找到最前面的文件的目录下
kafka-server-start.bat F:\kafka\kafka_2.11-2.2.0\config\server.properties
可以在小黑框中启动生产者消费者
kafka-console-producer.bat —broker-list localhost:9092 —topic testtopic
kafka-console-consumer.bat —bootstrap-server localhost:9092 —topic testtopic —from-beginning
查看主题 kafka-topics.bat —list —zookeeper localhost:2181
查看主题分区数 kafka-topics.bat —zookeeper localhost:2181 —describe —topic testtopic
修改主题分区数 kafka-topics.bat —alter —zookeeper localhost:2181 —topic testtopic —partitions 13（只能大于之前的）
删除主题
kafka-topics —delete —topic data_test —zookeeper localhost:2181
创建主题
kafka-topics.bat —create -zookeeper localhost:2182 —replication-factor 2 —partitions 3 —topic testMcdull222

如果查看主题失败，可以输入这两个再试试
export KAFKA_OPTS=””
export CLIENT_JVMFLAGS=””