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