如何克服Kafka连接器启动时的非法访问错误

yfjy0ee7  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(372)

我正在为Kafka连接写一个连接器。我在连接器启动过程中看到的错误是

java.lang.IllegalAccessError: tried to access field org.apache.kafka.common.config.ConfigTransformer.DEFAULT_PATTERN from class org.apache.kafka.connect.runtime.AbstractHerder

错误似乎发生在https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/abstractherder.java#l449
我需要设置这个吗 DEFAULT.PATTERN 手动?这不是默认设置。
我正在使用docker image confluentinc/cp-kafka:5.0.1. 我在连接器应用程序中使用的connectapi版本是org.apache。kafka:connect-api:2.0.0. 我在库伯内茨经营我的公司。

gz5pxeao

gz5pxeao1#

当我将映像更改为confluentinc/cp时,问题得到了解决-kafka:5.0.0-2.
在发布问题之前,我已经尝试过这个选项,但是pod处于挂起状态,拒绝启动。我想这可能是图像的问题。后来做了更多的研究,我才知道有时Kubernetes无法分配足够的资源,因此豆荚可以停留在等待状态。
我试过图片汇合公司/cp-kafka:5.0.0-2 and 很好用。

相关问题