Это, вероятно, глупый вопрос, но мне интересно, можно ли присоединить KStream к двум полям с помощью KTable / GlobalKTable? Например, скажем, у меня есть этот объект, который является значением записей в KStream.
{"gameId": 1, "awayTeamId": 1, "homeTeamId": 2}
У меня будет KTable / Topi c, который выглядит так -
{"teamId": 1, "teamName": "Team 1", "teamId": 2, "teamName": "Team 2"}
Я хочу присоединиться к awayTeamId и homeTeamId с помощью KTable, чтобы я мог обогатить сообщение так, чтобы результирующая запись выглядела примерно так ...
{"gameId": 1, "awayTeamId": 1, "awayTeamName": "Team 1", "homeTeamId": 2, "homeTeamName": "Team 2"}
Я предполагаю у вас может быть branch с одной ветвью, обрабатывающей соединение awayTeam, а другой branch, обрабатывающей соединение homeTeam, и, возможно, в конечном итоге создаст совершенно новую запись с вызовом map или mapValues и, возможно, объединит две отдельные ветви? Я не уверен, что это жизнеспособный метод или есть другие возможности, которыми стоит следовать.