kafka_handbook

…

创建 topic

/usr/local/kafka/bin/kafka-topics.sh --create --topic test_topic --zookeeper 10.25.151.169:2181 --partitions 20 --replication-factor 1

查看topic 信息

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic testLog --describe

消费

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testLog--from-beginning