wqpapa Sun, 12 Jan 2020 05:10:02 -0800
flink通过FlinkKafkaConsumer消费kafka主题,设置group.id按setStartFromGroupOffsets取偏移,如何在kafka端获取对应group.id的偏移信息? kafka为0.9版本,在zk那边找不到对应的group.id;通过kafka-consumer-groups.sh --describe --group ,也取不到。请问下要怎么获取啊?