有没有一种方法可以像其他侦听器属性一样使用spring boot application.properties文件设置属性ackOnError=false：spring.kafka.listener.ack-time
如果
浏览 25提问于2019-07-16得票数 2
回答已采纳
这里的问题是下次重新启动我的spring boot应用程序(或侦听器容器)时，相同的消息再次传递到侦听器，并遍历整个序列，最后到达死信。有什么方法可以避免这种情况吗？我禁用了自动提交，并设置了AckOnError(false)和AckMode(AckMode.RECORD)；
在SeekToErrorHandler中，我可以发现围绕SeekToUtil抛出异常的逻辑我还研究了org.springframework.kafka.listener.ContainerProperties中关于ackOnError(boolean
浏览 43提问于2020-02-18得票数 0
回答已采纳
我使用的是Spring Kafka 1.2.2.RELEASE，我有一个Kafka监听器作为消费者，它监听主题并在elastic中索引文档。
浏览 1提问于2018-03-21得票数 11
1回答
Kafka使用者异常和偏移提交
、、、、
我一直在为Spring做一些POC工作。具体来说，我想尝试一下在使用Kafka中的信息的同时处理错误的最佳实践。我想知道是否有人能够帮助：
}bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-group
浏览 4提问于2017-03-29得票数 17
回答已采纳
当我们将spring kafka升级到2.7.8时，我们在setAckOnError(false)方法中得到了错误，因为它已经被弃用了。现在有没有办法将错误的确认设置为false？
浏览 221提问于2021-11-16得票数 0
回答已采纳
我试图弄清楚如何处理在消息侦听器中发生的**瞬态错误**消费来自Kafka主题的消息。spring: bootstrap-servers: <HOST>:<PORT>
consumer容器属性ackOnError的默认值为true，因此容器将提交偏移量。因此，为了
浏览 5提问于2020-12-04得票数 0
1回答
我有一个kafka消费者应用程序，其中在侦听器方法中使用@Kafkalistener注解。我已经提供了主题名称和容器作为此注释的输入。此方法具有类型为Message和确认的参数。此方法侦听任何kafka消息，一旦接收、处理并存储在DB中。在此之后，我使用acknowledgement.acknowledge()方法手动提交偏移量。但是，我已经看到容器属性ackOnError默认设置为true。我希望获得相同的消息并处理它，直到它成功，并且不想将指针向前移动，如果移动指针，可能会导致消息丢失。为此，我计划采取以下方法。我使用的不是Sp
浏览 67提问于2019-10-10得票数 0
我有spring kafka消费者应用程序。应用程序充当传递，轮询来自kafka代理的消息并将其发送到IBM MQ。在发生故障时存储偏移量的最佳/简单化方法是什么？
浏览 1提问于2019-03-24得票数 0
1回答
我不完全理解提交偏移量和akcMode时消费者错误处理是如何工作的，以及错误时停止容器(使用Spring-Kafka1.3.*)是如何影响它的。我的理解是：
浏览 3提问于2018-07-09得票数 3
回答已采纳
背景:我正在构建一个kafka用户，它可以与外部apis对话，并将应答发回。JsonDeserializer.class);
factory.setConcurrency(this.configuration.getInt("
浏览 5提问于2017-05-17得票数 1
回答已采纳
获取以下eeror- org.springframework.kafka.KafkaException:发送失败；嵌套异常是60000 ms后元数据中不存在的org.springframework.kafka.KafkaException
浏览 5提问于2022-10-03得票数 0
回答已采纳
1回答
卡夫卡-基地1应该是默认的，卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供，例如: app.bridge.spring.cloud.stream.bindings.output.binder=kafka-qa2我的SCDF application.yaml包含两个绑定： cloud: applicationProperties: spring:
浏览 6提问于2017-02-03得票数 0
回答已采纳
在微服务架构中使用Kafka作为消息传递系统，我想知道首选的是Spring Kafka还是Spring Integration Kafka，为什么？另外，我们根据什么因素来决定选择哪一个？
浏览 75提问于2020-04-13得票数 2
=localhost:9092
spring.kafka.consumer.auto-offset-reset=earliestspring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consum
浏览 5提问于2019-10-17得票数 1
2回答
我试图为Kafka配置SSL (2.11-2.1.0)。*配置都没有被考虑在内，这使得目前不可能为Kafka配置SSL。
最后一种方法是产生麻烦的原因。我是不是遗漏了什么，是否有人成功地为kafka连接rest配置了SSL？
浏览 1提问于2019-03-18得票数 2
1回答
如何包含spring kafka的特定版本。Kafka版本依赖是由starter parent导入的2.5.14。但是我想用2.6.10版本覆盖它，我该怎么做呢？这是我的Spring Boot starter <parent> <artifactId>spring-boot-starter-parent</artifactId&g
浏览 47提问于2021-09-28得票数 0
回答已采纳
{
} }属性文件：
spring.kafka.consumer.auto-offset
浏览 0提问于2019-11-19得票数 3
回答已采纳
这是我的配置文件： brokers: localhost:9093
spring.cloud.stream.kafka.streams.binder.functions.processFoo.applicationId: foo-processorspring.cloud.stream.bindings.pro
浏览 4提问于2020-10-24得票数 1
回答已采纳
我想使用kafka和springboot实时地从文件中发送数据，我已经测试了这个代码，用postman以JSON格式将数据发送到kafka主题。
浏览 7提问于2022-11-07得票数 0
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号