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