我有以下用例：
我的应用程序无法处理的消息，可能是由于一些与网络相关的间歇性问题等，正在写入Kafka主题。
我想使用cron/scheduled task定期读取这些消息，然后处理它们。
到目前为止，我已经在我的springboot中使用了KafkaScript来满足我与kafka相关的需求，并且运行良好。
然而，我找不到一种方法来间歇性地使用Kafkafka阅读消息。
有没有办法在Spring做到这一点？如果有人能链接到文档或教程或描述一种方法来实现我想做的事情，我会很高兴。
我有以下用例：
我的应用程序无法处理的消息，可能是由于一些与网络相关的间歇性问题等，正在写入Kafka主题。
我想使用cron/scheduled task定期读取这些消息，然后处理它们。
到目前为止，我已经在我的springboot中使用了KafkaScript来满足我与kafka相关的需求，并且运行良好。
然而，我找不到一种方法来间歇性地使用Kafkafka阅读消息。
有没有办法在Spring做到这一点？如果有人能链接到文档或教程或描述一种方法来实现我想做的事情，我会很高兴。
2条答案
按热度按时间kxeu7u2r1#
您需要手动管理消费进程。如果您禁用
KafkaListener的autostartup功能，则可以。关于这一点有两种讨论。见下文：
Is there any example of Spring Schedule that reads Kafka topic?的
Spring Boot Job scheduler with Kafka consumer的
6fe3ivhb2#
尝试使用idleBetweenPolls参数，它将允许您定期读取
参见https：//docs.spring.io/spring-kafka/API/org/springframework/kafka/listener/ContainerProperties.html#setIdleBetweenPolls（long）