connectio未能使用ibm info sphere连接到kafka

jxct1oxe  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(358)

当我试图阅读infospfhere工作中的Kafka主题时,我犯了一个错误

Kafka_Customer: java.lang.NoClassDefFoundError: org.apache.kafka.clients.consumer.ConsumerRebalanceListener
at com.ibm.is.cc.kafka.runtime.KafkaProcessor.validateConfiguration (KafkaProcessor.java: 145)
at com.ibm.is.cc.javastage.connector.CC_JavaAdapter.initializeProcessor (CC_JavaAdapter.java: 1008)
at com.ibm.is.cc.javastage.connector.CC_JavaAdapter.getSerializedData (CC_JavaAdapter.java: 705)

Kafka_Customer: Java runtime exception occurred: java.lang.NoClassDefFoundError: org.apache.kafka.clients.consumer.ConsumerRebalanceListener (com.ibm.is.cc.kafka.runtime.KafkaProcessor::validateConfiguration, file KafkaProcessor.java, line 145)

我应该添加jar文件,它丢失了,但是在哪里以及如何才能看到哪个版本是nedeed?。在谷歌上搜索了很多遍之后,我什么也找不到。

z9gpfhce

z9gpfhce1#

kafka客户机jar版本向后兼容到0.10.2版本,但是我假设kafka处理器应该有这个版本,所以您可能需要联系ibm支持人员

相关问题