拆分后在Spring Cloud集成流中将所有消息放入kafka后执行方法

Question

如何在拆分后将所有消息放入Kafka后执行方法。

我尝试在频道后使用句柄（），但最终没有从第2条消息发布到Kafka。

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

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

Answer 1

由于您要拆分，并且只有在发送到Kafka之后，才可以捕获所有内容，除非之后聚合。您可以使用publishSubscribeChannel向Kafka和聚合器发送相同的消息。当聚合器释放组时，您可以很好地执行方法调用。