У меня есть сценарий, в котором есть потоковое приложение-производитель Kafka, создающее полезную нагрузку json для темы.
Я хочу создать потоковое приложение, в котором оно должно подсчитывать каждое сообщение, поступающее в эту тему, в течение каждого час. И ближе к концу каждого часа он должен вызывать метод, который должен создавать образец полезной нагрузки с указанием количества. Количество может варьироваться в зависимости от временного окна. Мне помогли чатгпт и второй пилот.
Похоже, ничего не работает. Для этого нужен пример Java-приложения.
Большое спасибо
Подробнее здесь: https://stackoverflow.com/questions/784 ... p-windowby
