kafka常用操作

如果把一个项目/微服务当成一个消费组，那么一个topic可能在多个消费组【一个topic被多个项目订阅】，一个消费组可能有多个topic。【一个项目订阅了多个topic】。一个消费组内的消费者个数也就是消费并行度。

当然一个项目/微服务也可能是多个消费组。

查看消费组下面的消费者

kafka-consumer-groups.sh
./kafka-consumer-groups.sh --bootstrap-server ip --describe --group logistics

查询topic：

kafka-topics.sh ./kafka-topics.sh --zookeeper ip --topic canal-product --describe

查看指定偏移量的消息

kafka-console-consumer.sh ./kafka-console-consumer.sh --bootstrap-server ip --topic order --partition 0 --offset 19831988 --max-messages 1

消费者移动到特定偏移量

kafka-consumer-groups.sh ./kafka-consumer-groups.sh --bootstrap-server ip --group courseop-order --topic order --reset-offsets --to-offset 19831988 --execute