使用@KafkaListener注释时，是否有重置偏移的标准方法？
我在我的Spring Boot应用程序中使用KafkaListener接口，它工作得很好。偏移量由Kafka本身存储。
现在，让我们假设一个主题的消费者部署了一个新版本，并且浪费了2小时的消息。然后，他们修复了应用程序，并希望启动新版本，与两个小时前有所不同。
我可以在以前的consumer.offsetsForTimes（）调用中使用consumer.seek（），但这只在使用轮询机制时是直接的，而不是在使用Spring KafkaListener时。
我尝试使用ConsumerBalanceListener，但要设置偏移量，我需要consumer处于活动状态，而在实例化ConsumerBalanceListener时，我没有这个功能。。。
我需要切换到轮询吗？在第一次调用KafkaListener之前，但在为使用者分配了分区之后，我是否可以访问该使用者？
共有1个答案
不并发；即将发布的2.0版本引入了消费者消息监听器，它支持将消费者作为参数传递到@KafkaListener方法中。
-
我使用@KafkaListener，我需要一个动态的主题名，所以我使用SpEL'\uu listener'来实现这一点 它工作得非常好。 主要问题是当我想添加另一个注释时，它会触发某些方面的编程 @MyCustomAnnotationToRecordPerformance@KafkaListener（主题 = "#{__ listener.my道具}"）公共无效监听器Kafka（@Payload
-
对于不改变实例状态的函数，方法的javadoc注释通常与Java-API中@return-tag的注释相同或非常相似。 boolean Collection.IsEmpty（） 如果此集合不包含元素，则返回true。 如果此集合不包含元素，则返回：true 现在我正在为许多简单的方法编写javadoc,比如getExpression（）,在这些方法中我遇到了同样的问题。我应该像在API中那样做还是
-
问题内容： 我已经四处寻找，没有运气。我 没有 使用Spring MVC，但仍想使用它来启用方法参数的验证。举个例子 使用MVC，可以通过简单的方法对带注释的Bean 启用此功能（请参阅5.7.4.3配置供Spring MVC使用的JSR-303验证器 ）。 使用AOP应该很简单。尽管如此，我怀疑有一些标准的方法可以做到这一点。因此出现了一个问题：对于非MVC应用程序和非控制器bean，是否有类似
-
我最近开始阅读注释。我在这里弃用了armStrong（）方法，我需要抑制弃用警告，但无论我放在哪里，它都会显示“不必要的@SuppressWarnings（“弃用”）”。 有没有人能告诉我应该把它放在哪里，这样方法就不推荐了，警告就不会再出现了？
-
问题内容： 例如： 要么 这些名称或破折号有问题吗？ 问题答案： 老实说，这取决于个人开发人员和他们自己的感受。就像您建议的那样，有两种同样好的构造CSS类的方法： 它们可以达到相同的目的，但是当您开始广泛思考时，您会发现这些样式之间的差距有多大。 分离班使他们可以重复使用： 该干的惯例是从不重复自己。通过分离or类，我们可以 重用 相同的类： 在第二种方法中-使用分隔符，代码将是： 在像这样的简
-
我正在使用spring boot 2.1.7.Release和spring-kafka 2.2.7.Release.并且我正在使用@KafKalistener注释来创建一个消费者，并且我正在使用消费者的所有默认设置。 根据apache kafka文档，'max.poll.records'的默认值是500。 在这里，我试图理解spring是如何处理记录处理的。现在我的问题是,如果我们已经在主题a上发