查询指定topic数据
./bin/kafka-console-consumer.sh --bootstrap-server kafka_host:port --topic topic_name --from-beginning
创建topic
./bin/kafka-topics.sh --create --topic topic_name --replication-factor 1 --partitions 4 --zookeeper 127.0.0.1:2181
删除topic
./bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete -topic topic_item_mysql
查看有哪些topic
./bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181
查看服务知否启动
netstat -tunlp|egrep "(2181|9092)"
查看kafka相关topic 状态
./bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic topic_item_mysql
查看相关group 消费情况
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group dw_test_kafka_consumer_000 --describe
