感谢回复！主要想了解下如何从kafka端后台命令方式获取对应消费组的偏移信息。之前通过普通的java代码消费kafka数据，通过kafka-consumer-groups.sh --describe可获取到消费偏移信息，但通过flink消费，不知道要怎么在kafka端获取偏移信息？
在 2020-01-12 21:17:40，"Benchao Li" <[email protected]> 写道： >setStartFromGroupOffsets >说的是从kafka里面保存的offset开始消费，flink并没有保证kafka一定会有这个consumer的offset，如果没有的话，会按照kafka >consumer的配置'auto.offset.reset'来设置这些partition的offset。 > >具体情况可以参考文档[1]. > >[1] >https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html#kafka-consumers-start-position-configuration > >wqpapa <[email protected]> 于2020年1月12日周日 下午9:09写道： > >> flink通过FlinkKafkaConsumer消费kafka主题，设置group.id >> 按setStartFromGroupOffsets取偏移，如何在kafka端获取对应group.id的偏移信息？ >> kafka为0.9版本，在zk那边找不到对应的group.id；通过kafka-consumer-groups.sh --describe >> --group ，也取不到。请问下要怎么获取啊？ > > > >-- > >Benchao Li >School of Electronics Engineering and Computer Science, Peking University >Tel:+86-15650713730 >Email: [email protected]; [email protected]
