在springboot应用程序中间歇性使用kafka消息
我有以下用例：
我的应用程序无法处理的消息，可能是由于与网络等相关的一些间歇性问题，正在写入kafka主题。
我希望使用cron/scheduled任务定期读取这些消息，然后处理它们。
到目前为止，我已经在我的弹跳靴中使用了KafkaListener来满足我与kafka相关的需求，并且运行良好。
但是，我无法找到一种方法来间歇性地使用KafkaListener阅读消息。
Spring有没有办法做到这一点？如果有人能链接到文档或教程，或者描述一种实现我想做的事情的方法，我会很高兴。
共有1个答案
您需要手动管理消耗的进程。如果您禁用KafkaListener的自动启动功能，则可能。
关于这一点有两个讨论。见下文：
有没有读Kafka题的春日课表的例子？
具有Kafka消费者的Spring Boot作业调度器
-
我有一个 Kafka 应用程序，我一直在使用它 kafka-console-consumer.sh 使用消息，如下所示： 它提供了我通过Kafka消费者给Kafka经纪人写的所有消息，没有任何遗漏。 最近，我将该应用程序部署在另一个环境中，因为某些原因，zookeperhost无法访问。所以我使用的是kafka简单的消费者外壳。sh，如下所示： 但是有了这个，我看到很少的消息(大约5000个中有2
-
我在src/main/resources下创建了2个文件： 应用程序。属性 第一个具有从env变量中获取值的属性，而后者具有固定值。 根据这里的具体情况，我以这样的方式推出了Spring靴： 然而，不会产生任何影响，并且应用程序是局部的。属性似乎被忽略。 有什么提示吗？
-
我是kubernetes的新手，需要在openshift平台上使用k8s confimap将springboot应用程序的属性文件外部化。我已将属性文件保存在git repo中，作为“greeter.message=Spring Bootmyapplication.properties已在库伯内特斯上挂载为卷！”并使用“oc create confimap myconfig--from-file=
-
我有Kafka Streams java应用程序启动并运行。我试图使用KSQL创建简单的查询，并使用Kafka流来实现复杂的解决方案。我希望将KSQL和Kafka流作为Java应用程序运行。 我打算通过https://github.com/confluentinc/ksql/blob/master/ksqldb-examples/src/main/java/io/confluent/ksql/em
-
我已经为Postgresql启用了复制，并且正在使用PGPool进行负载平衡。 我在使用HikariCP甚至Apache DBCP连接到Postgres时遇到了问题。 在SpringBoot应用程序中有没有使用PGPool的方法？ 请查找堆栈跟踪： 2018-08-10 10:20:19.124信息37879----[main]com.zaxxer.hikari.hikaridatasource：
-
我试图在SpringMVC中运行SpringBoot应用程序，在SpringMVCPOM中添加SpringBoot应用程序依赖项，并扫描SpringBoot包，但我面临以下问题