从不同的应用程序访问全局ktable或globalstore - kstream

Question

我们有 2 个微服务：

1. 负责消费消息并使用配置信息更新globalKtable（key = id，value = myObject）

2. 一旦使用某个 id 作为输入激活它，它应该查看配置 globalKtable 并通过该 id 检索数据

如何从app2访问该globalktable？ 应该添加 REST 层来检索信息还是 Stream 具有其他功能？

谢谢

Answer 1

Globalktable 是微服务本地的，它将从所有分区中获取所有数据并创建一个全局 KTable ，它实际上将数据保存在微服务本地内存中的 ROCKS DB 中。针对 Kafka key 的任何更新该主题将自动反映在 GlobalKTable 中。从第二个 MS 开始，如果您需要访问 globalKTable，则在第二个 MS 中创建相同的 GlobalKTable。