在Spring kafka消费者启动后运行一次方法
我有一个使用Spring kafka库的Spring启动应用程序的消费者。我想为每个消费者线程设置租户上下文，即在创建每个线程时调用一个方法（创建时每个线程只调用一次）。目前，我已将其添加到listner中，其中对方法有@KafkaListner注释，但它每次轮询并处理每条记录时都会调用它。我想在消费者线程启动时调用此方法一次。如果我们有任何这样的事情，请在这里帮助我。
共有1个答案
添加事件侦听器以侦听使用者启动的事件。它在同一线程上调用（默认情况下）。
https://docs.spring.io/spring-kafka/docs/current/reference/html/#events
https://docs.spring.io/spring-kafka/docs/current/reference/html/#event-consumption
-
我有一个spring boot服务，它使用Kafka主题。当我消费时，我会对Kafka信息执行某些任务。在执行这些操作之前，我需要等待服务将一些数据加载到我设置的缓存中。我的问题是，如果我将kafka consumer设置为autostart，它将在缓存加载并出错之前开始使用。 我试图在加载缓存后显式启动使用者，但却出现空指针异常。 Kafka利斯泰纳 要启动和停止的服务 主要方法 以下是例外情况
-
谁能建议在spring启动其kafka消费者之前如何运行初始化我的应用程序的方法？我正在使用spring的@KafkaListener注释创建一个kafka消费者
-
我正在使用Spring Kafka consumer,它从主题中获取消息并将其保存到数据库中。如果满足故障条件，例如db不可用，kafka消费者库是否提供重试机制？如果是，是否有方法设置不同的重试间隔，如第1次重试应在5分钟后进行，第2次重试应在30分钟后进行，第3次重试应在1小时后进行等。
-
在使用Spring Kafka Consumer时，我有时会收到以下错误消息。如代码片段所示，我至少实现了一次语义 1）我的疑问是，我是否错过了来自消费者的任何信息？ 2） 我需要处理这个错误吗。由于 org.apache.kafka.clients.consumer.提交失败异常：无法完成偏移提交，因为消费者不是自动分区分配的活动组的一部分；消费者很可能被踢出组。 我的SpringKafka消费
-
我将python kafka consumer的< code>auto_commit设置为< code>False，我正在手动提交消息。然而，重启后，消费者再次消费来自每个分区的最后一条消息。只有最后一个，不能再多。 这就是所展示的： 不知道为什么会显示滞后，whu当前偏移设置为最后一条消息而不是下一条？当我提交偏移量3时，当前偏移量不应该移动到4吗？ 我提交我使用的每条消息，但是在重启时，它总是
-
我需要使用consume process Product模式来处理Kafka消息，并已使用Kafka事务管理器配置了Spring Kafka侦听器容器，还设置了事务id前缀以启用Kafka事务。我正在使用批处理的ack模式，并试图了解在这种模式下，在事务中何时提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack模式批提交偏移量——在事务上下文中也是这样吗，即每个轮询1个事务？ 或者，在使用