将java中的多个表条目与kafka流结合

问题描述

所以我有一个包含文本类型和外键的文本条目的表。 该表被流式传输到 kafka。

喜欢:

文本 - 类型 - 外键

示例文本 - 2 - 3021

我现在想按外键对表条目进行分组,并将它们填充到新对象中。 此对象应包含每个外键的特定文本类型的文本条目。

例如,新对象应包含外键以及该外键的类型 2,4 和 5 的文本,这些文本安全地保存到每种文本类型的特定变量中。

外键 - TextDescriptionType - TextSummaryType - TextAdditionType

3021 - 示例描述 - 示例哑元 - 示例添加

我曾尝试将表格分组并在此之后聚合它们,但我无法让它适用于这个特定案例,而且我在网络上找不到任何类似的用例。 加入同一个ktable的情况相同。

我想知道是否有人有相同的用例以及他做了什么来处理它。

感谢阅读,如果有人问过这个问题,我很抱歉,但我找不到类似的问题。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)