0

尝试在 InfoSpfhere Job中读取 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 文件，但是在哪里以及如何查看需要哪个版本？经过大量的谷歌搜索后，我找不到任何东西。

4

1 回答 1

0

kafka-clients JAR 版本向后兼容到 0.10.2，但是我认为 Kafka 处理器应该有这个，所以你可能想联系 IBM 支持

于 2020-09-08T15:28:39.990 回答