Я хотел бы знать, что в моем приложении Kafka Streams или Spring-Kafka;
Есть ли способ, где я могу читать мои сообщения из топи c в некоторый интервал времени.
Считайте 1000 записей за 5 минут, скажем.
Считайте 1000 записей из топи c, снова подождите 5 минут и снова используйте 1000 сообщений.
Я прочитал .poll () документация, но она не делает то, что я на самом деле хочу. Это говорит
The configuration poll.ms is the maximum "blocking time" within poll() if no data avaliable.
Думайте как медленная обработка уведомлений. Могу ли я справиться с этим потребителем, производителем API или использованием потоков Кафки?
Спасибо!