基于kafka事件更新内存中的静态地图？

Question

我的应用程序部署在多个节点上，可以动态添加更多节点。 我有一个静态 java 映射来按 ID 存储一些配置。每当这些配置为 added/updated/deleted 时，我都会收到有关 kafka 主题的事件。我有一个消费者组，我需要在所有节点上更新这个静态地图。

作为参考，我不想为此使用任何其他数据库 - distributed/in-memory，等等。

请建议执行此操作的最佳方法 - 使用或不使用数据库。

Answer 1

您需要在每个节点上使用不同的group.id；一组中只有一个消费者可以从单个分区消费。