1回答
Spring Kafka producer默认保证发货吗？
spring-boot、spring-kafka
我想知道spring boot内部的spring kafka Producer是否保证交付。
有人知道如果某个随机监听器无法接收消息会发生什么情况吗？spring kafka是否会重试发送消息？
浏览 0提问于2019-05-29得票数 0
1回答
如何在Kafka listener ( spring -kafka)未初始化的情况下启动spring应用
spring、apache-kafka、spring-kafka
我正在开发一个使用spring-kafka的Kafka监听器的应用程序。我面临的问题是，当Kafka listener没有打开(各种原因，比如Kafka服务器没有打开或关闭)时，spring上下文初始化会失败。如何确保我的应用程序是独立的。
有谁能帮帮忙。
浏览 44提问于2017-09-10得票数 4
回答已采纳
1回答
如何重用Spring Kafka代码来设置多个监听器？
java、spring-boot、spring-kafka
如果我的应用程序只有一个监听器，情况就非常简单： 我将配置spring.kafka.*，Spring Boot会将配置解析为KafkaPropeties，并初始化所有需要的bean。但是我有两个监听器，假设一个将记录保存到文件，另一个保存到数据库。我希望尽可能多地重用Spring Boot约定。 我想配置file.kafka.*和db.kafka.*，将这些配置解析为2个KafkaProperties beans： @ConfigurationProp
浏览 59提问于2020-12-19得票数 1
1回答
Kafka -在Consumer中反序列化对象
java、apache-kafka、spring-kafka
我们正在考虑在我们的消息传递中使用Kafka，我们的应用程序是使用Spring开发的。因此，我们计划使用spring-kafka。 kafka: producer:
key-serializer: org.springframework.kafka.support.serializer.JsonSeriali
浏览 0提问于2018-06-29得票数 5
回答已采纳
1回答
kafka向所有具有相同group.id的消费者发送消息
apache-kafka、kafka-consumer-api、kafka-producer-api、spring-kafka
默认情况下，Kafka会将来自某个主题的消息发送到所有消费者组。 在我的例子中，我有一些需要重新调整的微服务。假设我们每一个都有三个实例。 我有一个服务，它为每个微服务提供必要的数据。
浏览 71提问于2019-01-14得票数 1
2回答
Spring Kafka在监听器中按条件丢弃消息
spring-boot、apache-kafka、spring-kafka
在我的Spring Boot/Kafka项目中，我有以下监听器：}
在监听器内部，我需要根据我的业务逻辑检查一些条件，
浏览 3提问于2018-08-06得票数 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。我有一个基于spring的监听器类(@KafkaListener)，每个消息处理大约需要6-7秒，因为它是一个资源密集型操作。我在这里注意到的是，监听器从未提交过偏移量，并且延迟永久地保持为"550“。 正因为如此(我认为)，消息被监听器无限期地处
浏览 20提问于2020-01-23得票数 0
1回答
禁用特定Spring Boot测试的Kafka侦听器
java、spring、spring-boot、apache-kafka、spring-kafka
如何在Spring Boot (2.2+)和Spring Kafka (2.4+)应用程序的@SpringBootTest测试中禁用@KafkaListener实例？目标是在特定测试中禁用Kafka侦听器，以便在不启动嵌入式Kafka代理的情况下运行此类测试。
浏览 39提问于2020-01-25得票数 3
回答已采纳
2回答
在spring boot kafka中的一个监听器中消费多个主题
spring-boot、apache-kafka、spring-kafka
有没有人能在spring boot kafka中给我举个小例子，我们可以在一个监听器类中使用多个主题。
浏览 2提问于2018-09-18得票数 1
1回答
DLT消息消耗
java、spring、spring-boot、apache-kafka、spring-kafka
我们使用的是Spring kafka 2.7非阻塞重试机制。在Spring Kafka重试机制中，kafka监听器消费来自main topic、Retry Topic和DLT topic的消息，我们只希望监听器消费来自main和retry topic的消息。
浏览 1提问于2021-10-14得票数 0
1回答
当自动缩放打开时，Kafka正在将协调器标记为已死
kubernetes、apache-kafka、spring-cloud-stream、spring-kafka
我们使用Kafka 0.10.2运行Kubernetes集群。在集群中，我们有一个由10个副本组成的副本集，这些副本运行我们的一个服务，这些副本将一个主题作为一个消费者组进行消费。在启用此功能后不久，我们开始在我们的Kafka队列中看到滞后。我查看了日志，看到消费者经常(几乎每隔5分钟)将协调器标记为已死，并在几秒钟后重新连接到同一协调器。我还经常在日志中看到：
org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed since如
浏览 1提问于2018-11-28得票数 1
2回答
如何在错误发生时停止使用kafka的消息，并在春季启动一段时间后重新开始使用
spring-boot、apache-kafka、spring-kafka
我有一个spring引导应用程序，我正在使用kafka主题的消息，并将消息存储在DB中。我有一个处理DB fail的要求，如果DB关闭，则不应该提交该消息，并在一段时间后暂停消费消息，然后监听器可以再次开始使用消息。做这件事的更好的方法是什么。i am using spring-kafka:2.2.8.RELEASE which is internally using kafka 2.0.1
浏览 9提问于2020-06-01得票数 1
1回答
我能从卡夫卡主题中读取特定的分区吗？
apache-kafka、spring-kafka
我正在使用spring框架来实现一个kafka侦听器。目前我正在读一个话题。但是，根据特定的需求，我被问到一种实现监听器的方法，它将从某个kafka主题中读取特定的分区。请您帮助我了解如何通过spring和java实现这一点。
提前谢谢。
浏览 2提问于2018-06-26得票数 3
回答已采纳
1回答
Kafka listeners，不使用Strings？
java、spring、apache-kafka
我正在遵循一个简单的指南文档来使用Kafka streams和spring boot (Spring guide) 我很清楚如何传入和传出消息，然后在中间我能够进行一些处理，替换@KafkaListener{KAFKA_CONSUMER_CONCURRENCY:3} destination: my-topic binderisolation.level: read_committed
浏览 34提问于2019-01-29得票数 0
2回答
Spring云流:标头kafka_acknowledgment值为空
spring-boot、spring-integration、spring-cloud-stream、spring-kafka
spring: stream: contentType: application/json type: kafka environment: spring:
浏览 0提问于2018-07-03得票数 0
回答已采纳
1回答
Spring-Kafka将ConcurrentKafkaListenerContainerFactory用于多个@Kafkalistener
java、spring-boot、apache-kafka、spring-kafka
我正在使用Spring-Kafka框架实现来自Kafka主题的消息消费。我正在尝试理解我为我的卡夫卡监听器创建的ConcurrentKafkaListenerContainerFactory的一些用法。我想知道我是否可以在我所有的监听器中重用ConcurrentKafkaListenerContainerFactory，或者我必须为每个@KafkaListener创建一个containerFactory
浏览 187提问于2020-04-26得票数 1
回答已采纳
1回答
如果我们在Kafka监听器中使用return语句会发生什么？
java、spring、spring-boot、apache-kafka、spring-kafka
我有一个可以批量消费消息的Kafka监听器。我也在使用手动提交。如果其中任何一条消息出现问题，我将使用返回语句，而不是提交偏移量(我希望再次处理所有这些消息)。我的问题是- 在Kafka Listener中使用return语句有副作用吗？再次消费相同的消息需要多长时间？ 我正在使用Spring Kafka和SpringBoot。
浏览 34提问于2021-04-26得票数 0
回答已采纳
1回答
Spring Kafka监听器暂停消息处理一定时间
spring-boot、apache-kafka、spring-kafka
在白天，我将通过Kafka主题接收实时更新，Spring Kafka监听器将消费和处理这些内容。但是，我想在EOD提要作业启动期间暂停Kafka侦听器，并在作业完成后恢复。 以下是我正在考虑的方法。当EOD提要工作开始时，我也想利用它来停止/启动Kafka侦听器。这将得到更同步的控制。 因为我对EOD工作有了更多的控制，什么时候开始，什么时候完成。在此期间，Kafka监听器可以根据时间表暂停。是否有其他方法可以在特定时间内停止Kafk
浏览 76提问于2021-03-02得票数 0
回答已采纳
1回答
Spring cloud stream kafka avro反序列化
avro、spring-cloud-stream、spring-kafka
我正在编写一个使用Avro消息的spring云流接收器应用程序。我试图让应用程序使用这些消息，但是我得到了以下错误。=0, kafka_receivedTopic=*****, kafka_receivedTimestamp=-1, contentType=avro/bytes}]
浏览 1提问于2018-09-19得票数 1
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号