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

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

喜欢：

文本 - 类型 - 外键

示例文本 - 2 - 3021

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

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

外键 - TextDescriptionType - TextSummaryType - TextAdditionType

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

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

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

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