我正在测试使用Apache在Kafka (0.8.2.1)上发送消息的简单生产者。我在camel中使用java创建了端点。在kafka上发送消息。但是当运行程序时,我得到了以下错误--注意:动物园管理员和Kafka已经启动,可以使用kafka控制台生成/消费消息。(KafkaProducer.java:54)
at org.apache.camel.component.kafka.
我有一个Apache路径,将AVRO消息发布到Apache主题上。(Producer.scala:33) at org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:84)另一方面,我有第二条Apache Camel路由,它应该从上面的主题中使用,失败的原因是
org.apache.avro.io.BinaryDecoder.innerLongDecode(BinaryDecoder.java