Проблема с маршрутизацией в Apache Camel с Кафкой - PullRequest
Новая
       19

Проблема с маршрутизацией в Apache Camel с Кафкой

0 голосов
/ 21 октября 2019

Мне нужно перенести сообщение из темы в Spring Bean.

Это мой маршрут в route.xml 

<route>
    <from uri="kafka:topic_name?brokers=10.1.1.1:9092;groupId=test_group"/>
    <to uri="bean:myBean?method=testMethod(${body}, 'topic_name')"/>
</route>

Мне кажется, что на этом маршруте нет вызова брокеру.

Но эта команда получает все сообщения 

kafka-console-consumer.sh --bootstrap-server 10.1.1.1:9092 --topic topic_name --from-beginning

Я также пытался отправлять сообщения в другую тему с другим маршрутом 

<route>
    <from uri="kafka:topic_name?brokers=10.1.1.1:9092;groupId=test_group"/>
    <to uri="kafka:test_topic?brokers=10.1.1.1:9092/>
</route>

Но также без особого успеха.

...