kafka基本指令

7.启动Kafka
先启动zookeeper
依次在各节点上启动kafka
启动集群与关闭集群
（1）. 依次在各节点上启动kafka:
bin/kafka-server-start.sh  config/server.properties
或者后台启动:
nohup /opt/modules/kafka_2.11-0.9.0.1/bin/kafka-server-start.sh  /opt/modules/kafka_2.11-0.9.0.1/config/server.properties &
（2）. 依次在各节点上关闭kafka
nohup /opt/modules/kafka_2.11-0.9.0.1/bin/kafka-server-stop.sh  /opt/modules/kafka_2.11-0.9.0.1/config/server.properties &


8.Kafka常用操作命令

(1).查看当前服务器中的所有topic
kafka-topics.sh --list --zookeeper hadoop-yarn1.beicai.com:2181
(2).创建topic
kafka-topics.sh --create --zookeeper hadoop-yarn1.beicai.com:2181 --replication-factor 1 --partitions 1 --topic topic-1609D
(3).删除topic
kafka-topics.sh --delete --zookeeper hadoop-yarn1.beicai.com:2181 --topic topic_1609D

通过shell命令发送消息(生产者)
kafka-console-producer.sh --broker-list hadoop-yarn1.beicai.com:9092 --topic topic-1609D
(4).通过shell消费消息（消费者）
kafka-console-consumer.sh --zookeeper hadoop-yarn1.beicai.com:2181 --from-beginning --topic topic-1609D

(5).查看某个Topic的详情
kafka-topics.sh --topic topic-1609D --describe --zookeeper hadoop-yarn1.beicai.com:2181
(6).新增配置
kafka-topics.sh --zookeeper hadoop-yarn1.beicai.com:2181 --create --topic my-topic