基于kafka事件更新内存中的静态Map?

myzjeezk  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(457)

我的应用程序部署在多个节点上,可以动态添加更多节点。我有一个静态javaMap来按id存储一些配置。每当这些配置被激活时,我就会收到一个关于kafka主题的事件 added / updated / deleted . 我有一个消费者组,我需要更新所有节点上的静态Map。
作为参考,我不想使用任何其他的数据库-分布式/内存等,。
请建议最好的方法来做到这一点-有或没有使用数据库。

dfuffjeb

dfuffjeb1#

你需要用不同的方法 group.id 在每个节点上;一个组只能从一个分区使用一个使用者。

相关问题