У меня запущено приложение kafka stream, которое будет принимать сообщения из темы всякий раз, когда новое сообщение публикуется в теме прослушивания.
KafkaStreams streams = new KafkaStreams(builder.build(), props);
streams.start();
Мне нужно периодически опрашивать тему для новых сообщений, из документации я попытался установить свойство " poll.ms " и значение в 1 минуту, но это не работает.
Есть ли другой способ, которым я могу опрашивать сообщения из темы kafka каждые X минут.