Jaming

反射input插件 kafka10时,报错

1

在InputFactor.java中46行，导致类型转换失败，不知道大神遇到过没，怎么解决 jlogstash start error:com.dtstack.jlogstash.inputs.Kafka10 cannot be cast to com.dtstack.jlogstash.inputs.BaseInput com.dtstack.jlogstash.factory.InputFactory.getInstance(46) com.dtstack.jlogstash.factory.InputFactory.getBatchInstance(64) com.dtstack.jlogstash.assembly.AssemblyPipeline.assemblyPipeline(103) com.dtstack.jlogstash.JlogstashMain.main(51)

老哥 kafka10的pom里面jlogstash是不是打包时也去掉

1

provided 不去掉的话 反射对象报错， 去掉了 启动的时候又找不到类了,看了一下 包里面是有这个类的 ERROR com.dtstack.jlogstash.inputs.Kafka10 [Kafka10.java:101] - kafka emit error org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.common.serialization.StringDeserializer for configuration value.deserializer: Class org.apache.kafka.common.serialization.StringDeserializer could not be found.