Combine multiple table entries in java with kafka streams

Question

so i have a table that contains text entries with a text type and a foreign key. This table is streamed into kafka.

Like:

Text - Type - Foreign Key

Example Text - 2 - 3021

I now want to group the table entries per foreign key and fill them into new objects. This objects should contain text entries of specific text types per foreign key.

Like for an example, the new object should contain the foreign key and the texts for type 2,4 and 5 for that foreign key safed into specific variables per text type.

Foreign Key - TextDescriptionType - TextSummaryType - TextAdditionType

3021 - Example description - Example dummary - Example addition

I have tried to group the tables and aggregate them after that, but i couldn't get it working for this specific case and i couldn't find any similar use case in the web. Same case for joining the same ktable.

I would like to know if anyone has the same use case and what he did to approach it.

Thanks for reading and i am sorry if this question was already asked, but i couldn't find a similar one.

question from:https://stackoverflow.com/questions/65871157/combine-multiple-table-entries-in-java-with-kafka-streams

Answer 1

Waitting for answers