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