腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1080)
视频
沙龙
1
回答
Spring
Kafka
@
KafkaListener
-
重试
发送
失败
消息
并
手动
提交
偏移量
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我使用@
KafkaListener
来消费来自
kafka
主题,我有一个应用程序逻辑来处理不同消费者组中的多个消费者的每个记录。 现在我的问题陈述是,-I必须将使用的
消息
发送
到第三方rest端点。如果
消息
发送
到rest-end点
失败
,则不应
提交
偏移量
,需要根据可配置的次数
重试
发送
消息
。在可配置的
重试
次数后,如果
发送
消息
失败<
浏览 83
提问于2019-02-12
得票数 2
回答已采纳
2
回答
Spring
Kafka
故障自动
提交
偏移量
spring
、
apache-kafka
、
spring-kafka
我使用的是
Spring
Kafka
1.2.2.RELEASE,我有一个
Kafka
监听器作为消费者,它监听主题并在elastic中索引文档。我的印象是,如果监听器中有异常(弹性关闭),则不应该
提交
偏移量
,并且应该在下一次轮询中处理相同的
消息
我的疑问是,为
浏览 1
提问于2018-03-21
得票数 11
1
回答
重试
永远处理
kafka
消息
会导致消费者重新平衡吗
java
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-retry
我有一个名为@
kafkalistener
的
kafka
消费者方法。我已经在容器上设置了
重试
模板,并且
重试
配置是这样的:如果在处理msg时发生了一些异常,它总是会
重试
。我将max-poll-records设置为1,如果这种情况是实时发生的,并且消费者一直在
重试
消息
,那么broker会不会认为这个消费者已经死了,
并
触发重新平衡?或者,在
重试
时,消费者是否会轮询处理
失败
的相同
消息
?如果这是真的,因为投票正在
浏览 21
提问于2019-10-16
得票数 0
1
回答
Spring
Kafka
重试
日志记录
spring-kafka
、
spring-retry
我有一个要求消费从
kafka
主题,做一些工作的记录,
并
产生到另一个主题与
spring
-
kafka
2.1.7。其他要求是事务性的只有一次语义,
重试
和错误handling.On
提交
记录
失败
我应该做3次
重试
,记录每个
重试
消息
重试
主题和
失败
的所有
重试
发送
记录到一个死信主题。我看过,它有很好的细节来解决这个问题。我正在努力的事情是如何记录每个
重试
浏览 5
提问于2018-08-02
得票数 0
回答已采纳
2
回答
Spring
KafkaListener
:如何知道何时准备就绪
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-kafka-test
我有一个简单的
Spring
Boot应用程序,它从
Kafka
读取和写入
Kafka
。我使用EmbeddedKafka编写了一个SpringBootTest来测试所有这些。主要问题是:有时测试会
失败
,因为测试过早地
发送
了
Kafka
消息
。这样,在
Spring
应用程序(或者更准确地说,是它的
KafkaListener
)准备就绪之前,
消息
就已经写入了
Kafka
。由于侦听器从latest
偏移量</em
浏览 0
提问于2019-04-11
得票数 8
1
回答
如何在
Spring
Boot中配置读取
Kafka
主题
消息
的频率(一天一次)
spring-boot
、
apache-kafka
、
kafka-consumer-api
我正在尝试处理
失败
,并将
消息
写入failure-Q,以防
消息
在db期间由于db停机或任何其他问题而
失败
。#
KAFKA
kafka
.topic.consumer.boot: 5000
spring
浏览 6
提问于2020-03-27
得票数 0
1
回答
使用
kafka
的Springboot网络流量
spring-boot
、
kotlin
、
reactive-programming
、
spring-kafka
、
reactor-kafka
我遇到了一些困难,试图理解一个用Kotlin编写的代码库,使用
spring
引导、网络流量和使用
spring
阅读卡夫卡主题的信息。控制器在下列文件中的签名:import reactor.core.Disposableinterface CreationEventConsumer { topics = ["\${topic.ea
浏览 11
提问于2022-11-09
得票数 0
回答已采纳
1
回答
春季卡夫卡-例外是导致手册立即承认被回滚?
spring
、
apache-kafka
、
spring-kafka
有人能帮助我理解为什么当异常发生时,
KafkaListener
会重新处理
手动
并立即
提交
的
消息
偏移量
吗?因此,我期待着以下行为:不知道我的理解是否正确?或者
Spring
会回滚我们在异常情况下所做的
手动
确认吗?我有以下侦听器代码: @
KafkaLis
浏览 16
提问于2022-07-14
得票数 1
回答已采纳
1
回答
Kafka
监听器方法异常时不
提交
offset
java
、
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我有一个
kafka
消费者应用程序,其中在侦听器方法中使用@
Kafkalistener
注解。我已经提供了主题名称和容器作为此注释的输入。此方法具有类型为Message和确认的参数。此方法侦听任何
kafka
消息
,一旦接收、处理并存储在DB中。在此之后,我使用acknowledgement.acknowledge()方法
手动
提交
偏移量
。现在,如果此行之前发生异常,则不会
手动
提交
偏移量
。但是,我已经看到容器属性ackOnEr
浏览 67
提问于2019-10-10
得票数 0
1
回答
Kafka
自动
提交
对较慢的事务不起作用
apache-kafka
、
kafka-consumer-api
、
spring-kafka
使用
Spring
Boot
Kafka
-v 2.2.1.RELEASE (使用
kafka
-clients.jar v 2.3.1) 我正在为我的
Kafka
代理使用confluent v5.1.2。我已经启用了自动
提交
为true,并且每隔3秒自动
提交
一次。 我有一个基于
spring
的监听器类(@
KafkaListener
),每个
消息
处理大约需要6-7秒,因为它是一个资源密集型操作。我在这里注意到的是,监听器从未
提交
过
浏览 20
提问于2020-01-23
得票数 0
3
回答
Kafka
消费者,处理某些
消息
失败
spring-boot
、
apache-kafka
、
kafka-consumer-api
我有一个弹簧启动应用程序与单一的
kafka
消费者,以获取一些主题的
消息
。但有时在处理
消息
时会发生错误。我希望像往常一样继续接收以下
消息
,同时能够不丢失该
消息
并
接收它,例如,下次服务在修复后与使用者重启时。 有可能做到这一点吗?我知道我需要禁用自动
提交
并
手动
提交
成功的
消息
,但是,在这种情况下,如果我没有对这个异常情况抛出任何异常,
并
手动
提交
下一个成功的
消息<
浏览 0
提问于2020-08-30
得票数 1
1
回答
Spring
Kafka
-如何使用@
KafkaListener
重试
spring
、
spring-boot
、
spring-kafka
来自Twitter的问题: 我只是想找出一个简单的使用
spring
-
kafka
2.1.7的例子,它可以使用
KafkaListener
和AckMode.MANUAL_IMMEDIATE来
重试
上一条
失败
的
消息
浏览 0
提问于2018-08-14
得票数 3
回答已采纳
1
回答
如何重新尝试春天卡夫卡版本2.2
spring-kafka
、
spring-retry
只是想找一个与
KafkaListener
一起工作的
Spring
-
Kafka
2.2的简单例子,
重试
最后一条
失败
的
消息
。如果
消息
失败
,则应将
消息
重定向到将进行
重试
的另一个主题。我们将有四个主题。如果主题
失败
,应将 topic 、 retryTopic 、sucessTopic和errorTopic重定向到retryTopic,其中将进行3次
重试
。如果这些尝试
失败
,则必
浏览 3
提问于2020-02-11
得票数 0
1
回答
使用ReplyingKafkaTemplate
手动
确认(
提交
)
kafka
消息
spring-boot
、
apache-kafka
、
spring-kafka
我使用ReplyingKafkaTemplate.sendAndReceive()
发送
和接收与关联id相关的
消息
。用例中有许多主题,我需要
手动
执行acknoledge (
提交
)消耗的
消息
偏移量
。到目前为止一切顺利,这是使用以下命令完成的: @SendTo("int1"ack.acknow
浏览 0
提问于2020-12-10
得票数 0
2
回答
Kafka
Kstream和
Spring
@
KafkaListener
有什么不同?
apache-kafka
、
spring-kafka
我对
Kafka
和阅读文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个主题,并且
消息
一到达就被处理。结果会回发到主题或数据库。
Spring
Kafka
注解@
KafkaListener
具有相同的功能。例如,我尝试过。在这里,我们也会监听一个主题,并在发布内容时对其进行处理。 所以我很好奇地想知道1.这2个有什么不同?
浏览 5
提问于2018-01-18
得票数 1
2
回答
调查()和commitAsync()在春季-卡夫卡
spring-boot
、
apache-kafka
、
spring-kafka
我试图在Springboot平台上用java编写一个
kafka
消费者应用程序。早些时候,我用普通java编写了代码,但现在转换为
spring
,因为它比普通java具有一些优势。似乎我不必在
spring
中显式轮询()循环,它将由@
KafkaListener
?自动处理。我已经设置了enable.auto.commit='false',因为在
提交
偏移之前我必须做一些处理,那么如何在
Spring
中执行commitAsync()呢?}")私有字符串
KAFKA<
浏览 7
提问于2020-09-20
得票数 3
回答已采纳
1
回答
春季云流卡夫卡-最终一致性-卡夫卡自动
重试
未确认的
消息
(当使用autocommitoffset=false)
spring-cloud
、
microservices
、
distributed-transactions
、
spring-cloud-stream
、
spring-kafka
我所遭受的痛苦之一是,当
消息
未被破坏时,必须处理
手动
重试
。 我可以肯定的是,当一条
消息
通过同步
发送
传递给卡夫卡时是肯定的。更重要的是,这也迫使我处理支付服务中的重复
消息
,以防它们被实际处理,但没有得到订单服务的答案。 我在想,如果消费者不承认
消息
的新
偏移量
,卡夫卡是否有一个
发送
重试
的内置机制。在<e
浏览 2
提问于2017-02-14
得票数 3
回答已采纳
1
回答
重启
Spring
应用程序后,
KafkaListener
无法接收
消息
java
、
spring-boot
、
apache-kafka
、
docker-compose
、
spring-kafka
但是,如果
Kafka
集群保持启动,但是
Spring
应用程序重新启动,则无法接收任何
消息
(函数正常工作)。属性文件:
spring
.
kafka
.bootstrap-servers=localhost:29092,localhost:39092
spring
.
kafka
.consumer.auto-offse
浏览 8
提问于2022-05-31
得票数 0
1
回答
春季卡夫卡消费者KafkaListenerErrorHandler对ErrorHandler。有什么关系?
apache-kafka
、
spring-kafka
假设:使用默认的
Spring
配置。每当在带有@
KafkaListener
注释的方法中发生异常时,就会调用这个处理程序。这将在处理错误(这只是一条日志
消息
)之后
提交
偏移量
(因为默认情况下isAckAfterHandle()返回true)。是否意味着当我们使用@
KafkaListener
注释时,错误从未在容器级别由ErrorHandler处理,而是由侦听器级别的KafkaListenerErrorHandler处理?如果容器级的在使用@<
浏览 14
提问于2021-11-16
得票数 0
2
回答
Spring
kafka
:
Kafka
Listener- consumer.seek问题
spring-kafka
我们使用的是
Spring
KafkaListener
,它在每个记录被处理到DB之后确认它。如果我们在写入数据库时遇到问题,我们不会确认记录,这样就不会为消费者
提交
偏移量
。这可以很好地工作。现在,我们希望在下一次轮询中获得
失败
的
消息
以
重试
它们。我们将errorhandler添加到我们的侦听器中,
并
调用ConsumerAwareListenerErrorHandler
并
尝试对
失败
的
消息
偏移量</
浏览 0
提问于2017-11-02
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
Kafka消息队列学习进阶(四)-优化(配置/代码/集群
你可能用错了kafka的重试机制
SpringBoot整合Kafka
3分钟带你了解「消息中间件」Kafka、RocketMQ
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券