apache-kafka - KafkaStream 加入 - 多个查找
问题描述
我们正在开发 kafkastream 实时应用程序,现在用例是将流与多个(最多 20 个)物化 KTable 连接。但是对于每个连接,我需要在 kstream 上执行 selectkey 操作以匹配所有查找
Emp<-> Dept
EmpWithDept<-> branch
EmpWithDeptbranch <-> Salary
EmpWithDeptbranchcurrency <-> customer
名单还在继续
我的帐户正在从所有这些查找中获取信息,并将其作为单个 json 发送给生产者。
这是最佳实践还是可以遵循的任何其他方法。
解决方案
推荐阅读
- microsoft-graph-api - PHPWord 和 O365 / Microsoft Graph
- python - 如何在 python 中为 catboost 编写 PR 曲线自定义评估指标?
- python - 从 3D 数据和相应的索引中获取等值面
- python - python 的 ENUM 值不正确
- rust - 在actix-web的主要方法中处理错误的最佳方法是什么?
- ionic-framework - 离子热点插件 getAllHotspotDevices
- python - 如何修复 sqlalchemy.exc.DataError: (psycopg2.errors.StringDataRightTruncation)?
- python - Keras Concatenate:“Nonetype”对象不可下标
- python - Python - 如何重塑两个向量并将其转换为元组?
- java - 如何有效地从 hdfs 读取 n 个文件夹并使用 Spark 在 hbase 中写回