Spring-Camel-Kafka：1 个消费者和多个主题不使用“camel-kafka”组件

Question

请在下面找到代码sn-p：

属性文件：

consumer.topic=FIRST,SECOND 
consumer.group=group1

Route.java：

from("kafka:{{kafka.url}}?topic={{consumer.topic}}&groupId={{consumer.group}}&autoOffsetReset=earliest&consumersCount={{consumer.consumersCount}}")

主题 FIRST 和 SECOND 被视为一个主题，而不是被视为两个不同的主题。有人可以帮我解释一下如何在属性文件中配置它们以解析为两个吗？

日志：

KafkaTopic[FIRST,SECOND]] Error while fetching metadata with correlation id 2159 : {FIRST,SECOND=INVALID_TOPIC_EXCEPTION}

Answer 1

Camel 2.17.0 不支持此功能。

从 Camel 2.17.1 和 Camel 2.18.x 开始引入了多主题订阅。

这是 2.17.x 分支上与此更改相关的提交： https://github.com/apache/camel/commit/a8f32d4ec485419cd196988f0de938d6f9b3cc49

这是与 2.18.x 分支上的此更改相关的提交： https://github.com/apache/camel/commit/d7fc67fa16d083e570650aa20c064d609b469641

您必须升级到 Camel >=2.17.1 或 2.18.x

为了完整起见，这里是 Camel JIRA 的问题 https://issues.apache.org/jira/browse/CAMEL-9835