kafka的基本命令
Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。
基本命令使用
列出所有可用的topic
1
| ./bin/kafka-topics.sh --list --zookeeper 172.20.40.51:2181
|
新建topic命令
1
| ./bin/kafka-topics.sh -zookeeper 172.20.40.51:2181 -topic seclogs -replication-factor 1 -partitions 3 -create
|
删除topic
1
| ./bin/kafka-topics.sh --delete --zookeeper 172.20.40.51:2181 --topic seclogs
|
查看kafka数据
1
| ./bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --broker-info --group yunwei-logstash --topic seclogs --zookeeper 172.20.40.51:2181
|