java.lang.NoClassDefFoundError: org/apache/kafka/connect/header/ConnectHeaders

Posted 2023-03-23

【中文标题】java.lang.NoClassDefFoundError: org/apache/kafka/connect/header/ConnectHeaders

【英文标题】：

【发布时间】：2021-04-08 01:48:38

【问题描述】：

我正在尝试使用 debezium 连接器创建一个连接器，以连接到 postgresql 和 kafka 连接。但是我看到了这个错误

[2020-12-31 21:52:20,251] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31)
java.lang.RuntimeException: java.lang.BootstrapMethodError: 
ERROR WorkerSourceTaskid=test-connector-poc-0 Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:172)
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:117)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.RuntimeException: java.lang.BootstrapMethodError: .

我尝试测试连接器的状态。它说状态失败并出现与上述相同的错误。

【问题讨论】：

你下载的是什么版本的Kafka？

@OneCricketeer 我正在使用 kafka_2.11-1.0.2。

@OneCricketeer 感谢您的提示。我升级到kafka_2.13，这个错误自动修复了。

2.13 不是 Kafka 版本；这是 Scala 版本。你从 1.0.2 升级到了一些东西

【参考方案1】：

在 Kafka 1.1.0 中使用 KIP-145 添加了连接标头

根据 cmets，您使用的是 Kafka 1.0.2