У меня есть данные, приходящие на kafka topi c, поскольку (ключ: id, {id: 1, body: ...}) означает, что ключ для сообщения совпадает с id. однако может быть несколько сообщений с одинаковым идентификатором, но разным телом. поэтому я получаю kstream <String, String>
Теперь я хочу получить все сообщения с одинаковым идентификатором (ключом) и объединить все значения в список и вернуть как
Kstream<String, List<String>>
Any sugessions