Connectio使用IBM Info Sphere失败到Kafka

问题描述

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

解决方法

kafka-clients JAR版本向下兼容至0.10.2，但是我认为Kafka处理器应具有此功能，因此您可能希望获得IBM支持