骆驼-Kafka动物园管理员例外

Question

    <route id="Test1" streamCache="true">
        <from uri="file:C:/data" />
        <split streaming="true">
            <tokenize token="\n" />
            <to uri="bean:proc1" />
            <to
                uri="kafka:localhost:9092?topic=Checking&amp;zookeeperHost=localhost&amp;zookeeperPort=2181&amp;serializerClass=kafka.serializer.StringEncoder" />
        </split>
    </route>

如果我部署war，我将得到以下异常：

原因：org.apache.camel.resolveEndpointFailedException：无法解析endpoint:kafka://localhost:9092？serializerClass=kafka.serializer.stringencoder&topic=checking&zookeePerhost=localhost&zookeePerport=2181，原因是：有2个参数无法在endpoint上设置。检查uri参数是否拼写正确，是否是终结点的属性。未知参数=[{zookeeperhost=localhost,zookeeperport=2181}]

我试图删除teh端口和zookeeper主机，它得到了部署，但消费者没有消费和放置在处理器中。

Answer 1

当使用camel-kafka时，版本<=2.16和>=2.17之间存在差异。

你用的东西适合2.16。

关于>=2.17，请参见http://camel.apache.org/kafka.html 2.17或更新部分。

from("direct:start").process(new Processor() {
                    @Override
                    public void process(Exchange exchange) throws Exception {
                        exchange.getIn().setBody("Test Message from Camel Kafka Component Final",String.class);
                        exchange.getIn().setHeader(KafkaConstants.PARTITION_KEY, 0);
                        exchange.getIn().setHeader(KafkaConstants.KEY, "1");
                    }
                }).to("kafka:localhost:9092?topic=test");