kafka常用命令

 运行控制台使用者来查看主题中的数据（或使用自定义使用者代码来处理它）：

./kafka-console-consumer.sh --bootstrap-server 172.16.7.140:9092,172.16.7.141:9092,172.16.7.142:9092 --topic tbl_issuecardinfo --from-beginning

 kafka-console-consumer.sh --zookeeper 172.16.7.140:2181 --topic tbl_issuecardinfo --from-beginning

从topic最后开始消费数据到控制台：

kafka-console-consumer.sh --bootstrap-server 172.16.7.140:9092,172.16.7.141:9092,172.16.7.142:9092 --topic tbl_issuecardinfo --offset latest --partition 0 

查看列表

kafka-topics.sh --zookeeper node02:2181 --list

查看topic描述

kafka-topics.sh --zookeeper node02:2181 --describe --topic tbl_issuecardinfo

创建生产者

kafka-console-producer.sh  --broker-list node02:9092,node03:9092  --topic tbl_issuecardinfo

创建topic

kafka-topics.sh --create --zookeeper node02:2181 --topic test_and_card_trade --replication-factor 2 --partitions 2

查看consumer

kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9292 --list

查看消费者组

kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9292 --list

lx_test

删除topic

./kafka-topics.sh --zookeeper 172.16.7.140:2128,172.16.7.141:2128,172.16.7.142:2128 --delete --topic tbl_issurecardinfo

看kafka消费者信息？

　　　　进入cd $ZOOKEEPER_HOME/bin下。

kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper txy001:2181 --group console-consumer-36989
查看kafka的offset
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list slave16.bdss.com:9092 --topic weixin --time -1 
kafka启用压缩格式：

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic streams-wordcount-output 
--config cleanup.policy=compact