慢慢来
分类: 大数据
2017-07-12 09:46:57
1. Create one topic
kafka-topics.sh --create --zookeeper c157rnb --replication-factor 2 --partitions 4 --topic test.myang
2. List topics
kafka-topics.sh --zookeeper c157rnb --list
3. Get topic offset
bin/kafka-run-class.sh kafka.tools.GetOffsetShell \
--broker-list localhost:9092,localhost:9093,localhost:9094 \
--topic test.myang \
--time -1
4. consume message from topic
kafka-console-consumer.sh --zookeeper c157rnb --topic ecpcibimbqm.esindexer.offset.master
* ? can specify the offset?