Как выполнить преобразование KTable в KTable?

Есть таблица KTable<String, GenericRecord>, необходимо преобразовать в другую таблицу KTable<String, GenericArray>, таким образом, чтобы сгруппировать в GenericArray значения из первой таблицы по ключу. Как это можно сделать?