kafka常用命令

到kafka目录下面执行命令：
nohup /usr/soft/kafka/kafka-server-start.sh
/usr/soft/kafka/config/server.properties &
 注意：会把生成的日志存放在nohup.out下面

下面的这种方式更好：
 /usr/soft/kafka/bin/kafka-server-start.sh /usr/soft/kafka/config/server.properties > /dev/null 2>&1 &
把标准输出和错误输出都写到了/dev/null中去了，/dev/null里面写什么都是空的。

//创建topic
/usr/soft/kafka/bin/kafka-topics.sh --zookeeper COS001:2181,COS002:2181,COS003:2181 --topic myTopic --replication-factor 2 --partitions 3 --create
/usr/soft/kafka/bin/kafka-topics.sh --create --zookeeper COS001:2181 --replication-factor 1 --partitions 1 --topic customerlog
/usr/soft/kafka/bin/kafka-topics.sh --create --zookeeper hadoop01:2181 --replication-factor 1 --partitions 3 --topic gamelog1

//查看当前服务器中的所有topic
/usr/soft/kafka/bin/kafka-topics.sh --list --zookeeper hadoop01:2181

//?查看某个Topic的详情
/usr/soft/kafka/bin/kafka-topics.sh --topic myTopic --describe --zookeeper mini1:2181

//?删除topic
/usr/soft/kafka/bin/kafka-topics.sh --delete --zookeeper hadoop01:2181 --topic myTopic
需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。

##客户日志生产者##
./bin/kafka-console-producer.sh --broker-list hadoop01:9092 --topic gamelog

##客户日志消费者##
/usr/soft/kafka/bin/kafka-console-consumer.sh --zookeeper hadoop01:2181 --from-beginning --topic gamelog