spring split后云集成流中所有消息放到kafka后执行一个方法

Question

拆分后所有消息都放到Kafka后如何执行一个方法

我试过在通道后使用 handle()，但最终没有将第二条消息发布到 Kafka。

 IntegrationFlowBuilder flowBuilder = IntegrationFlows
        .from(() -> jdbcTemplate....);
 flowBuilder.split();
 flowBuilder.channel(messageChannel);

我想在将所有拆分消息写入Kafka后执行一个方法。

Answer 1

因为你分裂了，只有在那之后才发送给卡夫卡，所以没有办法抓住所有的，除非aggregate之后。您可以使用 publishSubscribeChannel 向 Kafka 和聚合器发送相同的消息。当聚合器释放组时，您可以执行方法调用。