請找到下面的代碼片段:彈簧駱駝卡夫卡:1消費者和多個主題使用「駱駝卡夫卡」組件無法正常工作
屬性文件:
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和第二被視爲一個單一的主題,而不是被認爲是兩個不同的。有人可以幫助我解釋他們應該如何配置屬性文件作爲兩個解決?
LOG:
KafkaTopic[FIRST,SECOND]] Error while fetching metadata with correlation id 2159 : {FIRST,SECOND=INVALID_TOPIC_EXCEPTION}
什麼鈣的發行版梅爾你用嗎?並且您是否嘗試過使用更新的版本 –
駱駝版本:2.17.0 JDK:1.8 – poram