Flink1.12.0版本 FlinkStreaming 如何将偏移量提交到kafka 0.11

2021-04-06 文章 guanyq
flink 1.12版本 kafka版本0.11版本 目前可以消费,但是偏移量无法提交到kafka 我试过相同的代码,kafka版本2.4.1就可以提交偏移量到kafka 目前kafka 0.11版本有问题。无法提交。 有没有大佬帮忙想想办法。如何解决这个版本问题。

Flink1.12.0版本 FlinkStreaming如何将偏移量提交到kafka

2021-04-05 文章 guanyq
kafka版本0.11 目前查看消费组的解压情况,报消费组不存在。