首页 > 解决方案 > KafkaStream 加入 - 多个查找

问题描述

我们正在开发 kafkastream 实时应用程序,现在用例是将流与多个(最多 20 个)物化 KTable 连接。但是对于每个连接,我需要在 kstream 上执行 selectkey 操作以匹配所有查找

Emp<-> Dept
EmpWithDept<-> branch
EmpWithDeptbranch <-> Salary
EmpWithDeptbranchcurrency <-> customer

名单还在继续

我的帐户正在从所有这些查找中获取信息,并将其作为单个 json 发送给生产者。

这是最佳实践还是可以遵循的任何其他方法。

标签: apache-kafkaapache-kafka-streams

解决方案


推荐阅读