在springboot应用中间歇性消费kafka消息
Intermittently consuming kafka messages in a springboot application
我有以下用例：
我的应用程序无法处理的消息，可能是由于与网络等相关的一些间歇性问题，正在写入 kafka 主题。
我想使用 cron/scheduled 任务定期读取这些消息，然后处理它们。
到目前为止，我已经在我的 springboot 中使用 KafkaListener 来满足我与 kafka 相关的需求，并且运行良好。
但是，我找不到使用 KafkaListener 间歇性读取消息的方法。
在 spring 中甚至有办法做到这一点吗？如果有人可以 link 文档或教程或描述实现我想做的事情的方法，我会很高兴。
您需要手动管理消费进程。如果您禁用 KafkaListener.
的 autostartup 功能，则有可能
关于这个有两个讨论。见下文：
Spring Boot Job scheduler with Kafka consumer
我有以下用例：
我的应用程序无法处理的消息，可能是由于与网络等相关的一些间歇性问题，正在写入 kafka 主题。
我想使用 cron/scheduled 任务定期读取这些消息，然后处理它们。
到目前为止，我已经在我的 springboot 中使用 KafkaListener 来满足我与 kafka 相关的需求，并且运行良好。
但是，我找不到使用 KafkaListener 间歇性读取消息的方法。
在 spring 中甚至有办法做到这一点吗？如果有人可以 link 文档或教程或描述实现我想做的事情的方法，我会很高兴。
您需要手动管理消费进程。如果您禁用 KafkaListener.
autostartup 功能，则有可能
关于这个有两个讨论。见下文：
Spring Boot Job scheduler with Kafka consumer