创建MSK Sink Connector时遇NoSuchMethodError错误求助

问题根源 #

核心错误是 java.lang.NoSuchMethodError: 'boolean org.apache.kafka.common.utils.Utils.isBlank(java.lang.String)'——该方法是Apache Kafka 2.8.0及以上版本新增的API，但你的MSK Connect运行环境是2.7.1版本，不支持这个方法。你下载的Confluent JDBC Connector插件版本过高，依赖了高版本Kafka的API，导致兼容性冲突。

解决方案 #

• 匹配Connector版本：Confluent JDBC Connector版本需与Kafka Connect版本对应。针对Kafka Connect 2.7.x，应使用Confluent Platform 6.1.x配套的JDBC Connector（Confluent 6.1.x与Apache Kafka 2.7.x版本兼容）。
• 替换插件包：移除当前使用的高版本JDBC Connector插件，下载适配Confluent 6.1.x的版本，重新部署到MSK Connect的插件目录中。
• 验证依赖一致性：确保Connector的依赖库与MSK Connect内置的Kafka客户端版本完全匹配，避免因API差异引发类或方法缺失问题。

内容的提问来源于stack exchange，提问作者Marcin