命令行消费
1
| bin/kafka-console-consumer.sh --bootstrap-server ip:port --topic $topic
|
查看group对集群消费情况
1
| bin/kafka-consumer-groups.sh --bootstrap-server ip:port --describe --group $group
|
重置offset
1
2
3
| bin/kafka-consumer-groups.sh --bootstrap-server ip:port --group $group --reset-offsets --all-topics --to-datetime 2019-11-03T00:00:00.000 --execute
## --execute 参数会执行生效，不加则只显示结果
|
topic 创建
1
| bin/kafka-topics.sh --create --zookeeper 192.168.21.179:2181 --topic $topic --partitions 3 --replication-factor 1
|
查看所有topic
1
| bin/kafka-topics.sh --zookeeper 192.168.21.179:2181 --list
|
生产消息
数据查询分析组件。
走引擎， 不走引擎. 消息路由。 一部分消息 都走。
变量的管理等存在很大的灵活，及不可控。