我使用Spring KafKa，并将ackMode设置为MANUAL_IMMEDIATE props.setAckMode(AbstractMessageListenerContainer.AckMode.MANUAL_IMMEDIATE
浏览 53提问于2019-02-05得票数 0
回答已采纳
1回答
编辑2:可以在大日志中看到更多的此异常，这些异常由: org.springframework.kafka.KafkaException: Interrupted (排队时中断)造成
浏览 3提问于2020-06-08得票数 0
回答已采纳
1回答
我有一个使用Spring实现的Kafka消费者： prop.setMessageListener(this);
prop.setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATErecord, Acknowledgment ac
浏览 0提问于2021-06-08得票数 0
1回答
这是我们在负载测试环境中看到的Kafka重复消费场景的概念描述：
在单独的EC2实例上给出两个应用程序实例，其中包含一个Kafka使用者，每个使用者组ID都是相同的。给定启用了AckMode、MANUAL_IMMEDIATE和syncCommits的单线程MANUAL_IMMEDIATE。我不这么认为，而且我也很难理解同步消费者是如何做到的。我的理解是侦听器线程总是按顺序进行轮询和消耗，并且分区撤销发生在轮询过程中。我们使用的是kafka-客户端版本3.1.1和sp
浏览 6提问于2022-11-17得票数 0
我注意到了春季卡夫卡即将推出的一个功能：手册:消息侦听器负责确认()确认。然后，应用与批处理相同的语义。
问题2:假设我被困在春天卡夫卡2.7的土地:我有一个听众，产生信息的另一
浏览 3提问于2021-08-26得票数 0
我试图为在manual offset commit上接收到的消息实现kafka。我已将偏移量提交设置为false，但偏移量值不断增加。application.yml application: resources: bootstrapServers: localhost:9092 ena
浏览 0提问于2019-11-12得票数 5
回答已采纳
1回答
立即更新Kafka偏移量
、、、、
卡夫卡版本是kafka_2.12-1.1.0spring: bootstrap-servers: kafka:90
浏览 0提问于2018-10-17得票数 0
回答已采纳
我有一个Kafka侦听器，它使用以下属性实现确认消息侦听器接口：
在使用侦听器上的消息时此外，我还有一个场景可以在X分钟后(如果没有消息到达)对最后一个偏移号(将其保存在内存中)进行修改。
浏览 0提问于2019-07-10得票数 4
回答已采纳
当ackMode设置为MANUAL_IMMEDIATE时，如果@KafkaListener方法根本不调用acknowledgement.acknowledge()，但成功退出该方法而没有任何异常，会发生什么情况问题here似乎解决了同样的问题，但从来没有收到关于当没有异常时会发生什么的答案，因为我认为错误处理程序和恢复器只有在抛出异常时才会起作用，而不是在消息未确认的情况下。
浏览 241提问于2020-11-04得票数 0
1回答
我试图找到在Kafka消费者中手动提交偏移的方法，使用Spring (1.1.0.RELEASE)。我知道有两种方法-
ConcurrentKafkaListenerContainerFactory.getContainerProperties().setAckMode(AbstractMessageListenerContainer.AckMode.MANUAL_IMMEDIATE)；@KafkaListener(
浏览 1提问于2018-06-13得票数 3
为此，在我的application.properties中，我设置了spring.kafka.properties.enable.auto.commit=false @Headers MessageHeaders headers)@KafkaListener(id="${"+ Kafka
浏览 3提问于2020-01-14得票数 0
回答已采纳
问题是，每当调用错误处理程序，而我手动地寻求某种偏移量时，偏移量似乎没有提交给Kafka。事实证明了这一点，即在应用程序重新启动之后，它会轮询相同的(以前失败的)记录(即使代码寻求下一个记录)。我尝试过使用不同的AckMode，例如MANUAL或MANUAL_IMMIDIATE，但这不会改变观察到的行为。此外，文档还为这些模式提供了如下内容：
手册，MANUAL_IMMEDIATE要求侦听器是AcknowledgingMessageListener或BatchAcknowledgingMessageListener<em
浏览 4提问于2019-12-06得票数 0
回答已采纳
问题在于Spring应用程序:每当我启动它时，它都会从Kafka读取相同的消息。这意味着偏移量没有被保存。我该怎么解决呢？版本有：kafka_2.12-2.4.0，Spring Boot 2.5.0。在卡夫卡的听众bean里，我有当Spring启动时，控制台上打印的使用者配置值如下);
但是，这与ack模式manual_immediate不兼容，
浏览 1提问于2021-06-10得票数 1
回答已采纳
我试图弄清楚如何处理在消息侦听器中发生的**瞬态错误**消费来自Kafka主题的消息。spring: bootstrap-servers: <HOST>:<PORT>
consumer如果重新启动侦听器，由于偏移量已经提交并向前移动，该消息不再由使用者组中的任何其他客户端处理；无异常/错误
浏览 5提问于2020-12-04得票数 0
{ * and publish to kafka, once receive the success message */message.acknowledge();问题:如果卡夫卡经纪人倒下了，该怎么办重试？我
浏览 11提问于2021-09-28得票数 0
回答已采纳
我想实现的场景是从Kafka消费一条消息，处理它，如果某个条件失败，我不希望确认该消息。如果设置为false，则确认标头将在邮件标头中可用于延迟确认。我的问题是，在将autoCommitOffset设置为false后，如何确认消息？代码示例将不胜感激。
浏览 2提问于2016-06-15得票数 2
2回答
如果你已经做过相关工作，请有人在下面澄清一下。问题- 1：根据Spring文档，有两种实现Kafka-的方法；“您可以通过配置MessageListenerContainer和提供消息侦听器或使用@KafkaListener注释来接收消息”。我猜如果我使用普通的消息侦听器，那么在处理每一条消息后都会提交偏移。 public void onMessage(List<ConsumerRecord<String, String>> records, Ac
浏览 0提问于2019-04-11得票数 16
回答已采纳
3回答
用于消息处理的多个节点
、、、、
我们在Kubernetes上部署了一个spring引导应用程序来处理消息:它从Kafka主题中读取，然后执行一些映射，最后，它写到Kafka主题。
浏览 6提问于2020-04-24得票数 0
1回答
如何从与不同经纪人相关的多个Kafka主题中消费？
我有一个Spring应用程序，需要使用两个主题，但是主题与不同的Brokers相关联。
浏览 4提问于2021-02-19得票数 1
回答已采纳
我正在测试Spring Kafka批处理侦听器，批处理确认模式，一次轮询3条记录，并将这些记录持久存储到数据库中。当Spring Boot应用程序重新启动时，我看到另外3条记录正在被使用和处理。如果批处理大小更大(500)，并且在关闭过程完成之前无法将记录持久化到数据库，该怎么办？我们如何确保这些消息不会丢失或处理这种情况？2021-09-21 22:37:22,448 INFO [org.springframework.kafka.KafkaListenerEndpointConta
浏览 46提问于2021-09-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
