Мое требование заключается в том, чтобы я получил файл JSON из раздела Kafka в Kafka Stream, из которого мне нужно сгруппировать записи JSON на основе ключей, а затем выгрузить эти записи в разные каталоги, названные в честь ключей.
Например: у меня есть файл с разными записями JSON с ключами «A», «B», «A» и «C».
Мне нужно, чтобы вышеуказанные записи были выгружены в разные каталоги,то есть.Каталог A будет создан, и запись с ключом JSON «A» войдет в файл в этом каталоге.Каталог B будет создан, и две записи для ключа «B» перейдут в файл в этом каталоге и т. Д.