Как я могу выполнить метод после того, как все сообщения будут отправлены в Кафку после разделения.
Я пытался использовать handle() после канала, но это не привело к публикации второго сообщения в Kafka.
IntegrationFlowBuilder flowBuilder = IntegrationFlows
.from(() -> jdbcTemplate....);
flowBuilder.split();
flowBuilder.channel(messageChannel);
Я хотел бы выполнить метод после записи всех разделенных сообщений в Кафку.
Так как вы разделяетесь и только после этого отправляете к Кафке, нет никакой возможности поймать их всех, разве что aggregate
потом. Вы можете сделать это с помощью publishSubscribeChannel
, чтобы отправить Kafka и агрегатору одно и то же сообщение. Когда агрегатор выпускает группу, вы можете выполнить вызов метода.
Спасибо, с помощью подписки на публикацию я смог агрегировать, а затем использовать дескриптор.