flink1.15中kafka source、sink对kafka-client的版本要求是否可降低

[yidan zhao]

如题，我想问下相关了解的同学，目前只是升级 kafka-client 新版本，换了下接口用法。还是依赖到部分新版本client才有的功能呢？
是否有可能基于低版本 kafka-client 实现呢？

可以的话我可能自己覆盖实现下。
因为高版本kafka-client不支持公司的kafka，公司kafka是开源kafka外层加了一层proxy。使用太高版本kafka
client访问会有问题（推荐的是0.11，我测试最多到2.2的client）。