Создать поток Kafka, который запускается каждый день в определенное время в Java

Question

Как создать поток Kafka, который запускается ежедневно в определенное время, читает сообщения из темы, выполняет некоторые преобразования и записывает сообщения обратно в другую тему.

Например, поток, который запускается ежедневно в 21:00извлекает все сообщения, отправленные в тему, и записывает их в другую тему.

Я пытался работать с окнами, но все примеры касались только агрегации.Я не должен делать агрегацию.Я использую Java DSL

Answer 1

Напишите свой код Java, чтобы делать то, что вы хотите, и настройте crontab для запуска Java, когда вы хотите.