kafka官网下载 kafka_2.12-3.0.0.tgz
解压启动：
> tar -xzf kafka_2.12-3.1.0.tgz cd kafka_2.12-3.0.0
zookeeper配置修改config/zookeeper.properties：
#修改为自定义的zookeeper数据目录 dataDir=/usr/local/kafka/zookeeper #修改为自定义的zookeeper日志目录 dataLogDir=/usr/local/kafka/log/zookeeper # 端口 clientPort=2181
后台启动Zookeeper服务。
./bin/zookeeper-server-start.sh config/zookeeper.properties &
kafka配置修改config/server.properties：
broker.id=0 listeners=PLAINTEXT://192.168.100.200:9092 zookeeper.connect=192.168.100.200:2181
后台启动kafka：
./bin/kafka-server-start.sh config/server.properties &
停止
./bin/kafka-server-stop.sh config/server.properties
创建主题
./bin/kafka-topics.sh --create --bootstrap-server 192.168.100.200:9092 --replication-factor 1 --partitions 1 --topic test123
删除主题
./bin/kafka-topics.sh --delete --bootstrap-server 192.168.100.200:9092 --topic test123
查看主题列表
./bin/kafka-topics.sh --bootstrap-server 192.168.100.200:9092 --list ./bin/kafka-topics.sh --bootstrap-server 192.168.100.200:9092 --topic test123 --describe
启动生产者
./bin/kafka-console-producer.sh --broker-list 192.168.100.200:9092 --topic test123
启动消费者
./bin/kafka-console-consumer.sh --bootstrap-server 192.168.100.200:9092 --topic test123 --from-beginning
