У меня есть следующий фрагмент кода для ежечасной агрегации данных на основе времени события...

Я написал этот код в потоковом приложении Kafka: KGroupedStream<String, foo> groupedStream =...