Hello, I was using dynamicRouter to compute destination of messages through my JMS queues routes. Now, I want to replace these JMS queue routes by Kafka topics and still using dynamicRouter to determine which route should consume a particular messages.
*example:* from(kafka:topic1).to(dynamicRoute(method(DynamicRouting.class, "nextStep")); > DynamicRouting.class returns for example kafka:topic2 endpoint from(kafka:topic2).to(dynamicRoute(method(DynamicRouting.class, "nextStep")); > DynamicRouting.class returns for example kafka:topicN endpoint ... But when I do that, my program is stuck in a infinite loop. I would like to know if what I am doing is possible ? Thanks
