У меня есть этот маршрут:
@Component
public class MyRoute implements RouteBuilder {
@Override
public void configure() {
from(topic)
.routeId(routeId)
.process(exchange -> {
// do something
}
.process(exchange -> {
// do something
}
.to(anotherTopic);
}
}
Я хочу обрабатывать больше сообщений из темы параллельно, а не последовательно.
Сообщение используется из очереди kafka и должно быть транзакционным.
Как мне это сделать?