我正在调查FLINK-28060问题。我认为它已经解决了，它将作为已解决的一个包含在Apache Flink 1.15.1中。当我在发布说明中查看ApacheFlink的发布说明时，1.15.1的问题仍然没有解决。但jira问题已经结束，解决级别也已确定。在1.16版本中，该问题将被包括在内，但我想知道为什么这个问题不包括在1.15.1或1.15.2中，而是包括在1.16中？此问题是否有特殊原因需要稍后更新？
否，Flink 1.15.1中没有解决该问题。直到1.15.1发布很久之后，才对Kafka进行了必要的修复。
FLINK-28060是由一个错误引起的，该错误在与FLINK 1.15.0捆绑的Kafka版本中引入到Kafka中。Kafka社区最近提供了对Kafka客户端的必要修复，Flink社区决定在1.16.0完成之前有足够的时间彻底测试这个新的Kafka版本，因此它将包含在其中。
如果您使用的是Flink 1.15.x，并且受到这个错误的困扰，那么您可以通过从JAR中排除与Flink捆绑的kafka客户端的错误版本来解决这个问题，并根据新版本进行构建。(这应该是可能的，除非您运行的是纯SQL作业，而不是提交JAR文件。(