Confluent Kafka 7.7.1下HTTP Sink Connector启动失败求助

核心错误根源 #

从日志堆栈信息可明确，启动失败的核心原因是缺少依赖类io.confluent.connect.utils.validators.Validators，触发了ClassNotFoundException和后续的NoClassDefFoundError。该类属于Confluent Connect工具包，通常是HTTP Sink Connector依赖库未完整安装或版本不匹配导致的。

具体问题拆解 #

1. 版本兼容性问题
   你使用的是Confluent Kafka 7.7.1，但安装的HTTP Sink Connector版本为1.7.7。较旧的Connector版本依赖的Confluent工具类，在新版本平台中可能存在路径变更或依赖结构调整，导致无法找到目标类。

2. 配置文件语法错误
   配置文件中存在两处明显问题，会干扰配置解析和Connector正常工作：

• confluent.topic=firstTopic：该配置是指定Confluent内部用于存储Connector配置、偏移量的topic，不是业务消费topic。你错误地将业务topic赋值给这个参数，同时注释了正确的topics=firstTopic，会导致Connector无法定位要消费的数据源。
• http.headers="Content-Type:application/json|Accept:application/json"：properties文件中字符串值无需添加双引号，此处的引号会被当作值的一部分，引发HTTP头解析失败。

修复方案 #

1. 解决依赖缺失问题 #

• 使用Confluent Hub安装与Confluent Platform 7.7.1兼容的HTTP Sink Connector版本：

  confluent-hub install confluentinc/kafka-connect-http:latest
  

  或参考Confluent官方版本兼容性矩阵，选择匹配7.7.1的Connector版本进行安装。
• 检查Connector安装目录的lib文件夹，确认confluent-connect-utils相关jar包存在，若缺失需手动添加对应版本的依赖包。

2. 修正配置文件错误 #

修改my-http-sink-connector.properties中的错误配置：

# 恢复业务topic的正确配置，注释错误的confluent.topic赋值
topics=firstTopic
# confluent.topic=firstTopic

# 移除http.headers值的双引号
http.headers=Content-Type:application/json|Accept:application/json

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