单机Kafka部署文档

单机Kafka部署文档

##启动服务
nohup bin/kafka-server-start.sh config/server.properties &

##创建topic
kafka-topics.sh --create --topic mcd --replication-factor 1 --partitions 1 --zookeeper 192.168.113.129:2181

## 查看所有topic
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

##生产者
bin/kafka-console-producer.sh --broker-list 192.168.113.129:9092 --topic test

##消费者
bin/kafka-console-consumer.sh --zookeeper 192.168.113.129:2181 --topic test --from-beginning

常用命令

 http://www.cnblogs.com/qizhelongdeyang/p/7341954.html