我有一个要求，即应用程序在 Kafka 主题中为 1 批发送 n 条异步消息以进行某些处理。我想在 Kafka 消费者处集成 Spring 聚合器，以便在处理完该批次的所有消息后生成一个事件。我的问题是，我如何将聚合器集成到分布式环境中，因为同一批次有多个 Kafka 消费者？我们是否应该将其与任何内存数据库（如 Hazelcast）集成？
【问题讨论】：
标签： java spring spring-boot spring-integration enterprise-integration
没错。您需要使用一些共享持久存储配置该聚合器：https://docs.spring.io/spring-integration/docs/current/reference/html/message-routing.html#reaper。
Hazelcast 没有 MessageGroupStore 实现：https://github.com/spring-projects/spring-integration-extensions/tree/main/spring-integration-hazelcast。但是您可以考虑使用我们的实现中可用的任何内容：https://docs.spring.io/spring-integration/docs/current/reference/html/system-management.html#message-store
欢迎就 Hazelcast 扩展的问题投稿！
【讨论】：