当我试图阅读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?。在谷歌上搜索了很多遍之后,我什么也找不到。
1条答案
按热度按时间z9gpfhce1#
kafka客户机jar版本向后兼容到0.10.2版本,但是我假设kafka处理器应该有这个版本,所以您可能需要联系ibm支持人员