У меня есть случай, когда каждую секунду 5k сообщений отправляются в тему kafka. На стороне потребителя Kafka мне нужно собирать все сообщения за этот час и ежечасно записывать файлы. Мы только начинаем работу в Kafka Streams и задаемся вопросом:этот вариант использования для агрегации почасовых сообщений является правильным выбором для потоков Kafka.Спасибо!