1回答
我一直在关注这个 Creating KafkaListener without Annotation & without Spring Boot 我有一个API，所以每当调用API时，都会使用新的消息侦听器创建一个新的容器监听器将获取某些偏移量的消息，然后它将暂停。在那之后，我就不需要它了。但是当API被多次点击时，就会产生大量的对象。我想销毁那些无用的东西。 我在想，当一个监听器<
浏览 85提问于2021-04-29得票数 0
我们正在考虑在我们的消息传递中使用Kafka，我们的应用程序是使用Spring开发的。因此，我们计划使用spring-kafka。
生产者将消息作为HashMap对象放入队列。我们有JSON序列化程序，我们假设映射将被序列化并放入队列中。下面是生产者配置。value-serializer: org.springframework.kafka.support.serializer.J
浏览 0提问于2018-06-29得票数 5
回答已采纳
我想知道spring boot内部的spring kafka Producer是否保证交付。
有人知道如果某个随机监听器无法接收消息会发生什么情况吗？spring kafka是否会重试发送消息？
浏览 0提问于2019-05-29得票数 0
在我的Spring Boot/Kafka项目中，我有以下监听器：}
在监听器内部，我需要根据我<em
浏览 3提问于2018-08-06得票数 0
回答已采纳
总的来说，我对Java、Spring和Kafka都很陌生。ArrayBlockingQueue，我希望它将Kafka的消息添加到监听器中。我遇到的问题是，我不知道如何将一个ArrayBlockingQueue传递给侦听器，因为Spring在幕后处理侦听器的实例化和运行。我需要这个阻塞队列，以便监听器之外的另一个对象可以访问消息并
浏览 1提问于2018-09-17得票数 0
回答已采纳
使用Spring cloud Stream Kafka监听器从kafka主题中读取消息，并在异常情况下将消息发送到死信队列，配置属性 spring.cloud.stream.kafka.bindings.input.consumer.enable-dlq=true
spring.cloud.stream.kafka.bindings.input.consumer.dlq-name=book_error 我可以向DLQ
浏览 15提问于2020-01-26得票数 1
我有一个spring引导应用程序，我正在使用kafka主题的消息，并将消息存储在DB中。我有一个处理DB fail的要求，如果DB关闭，则不应该提交该消息，并在一段时间后暂停消费消息，然后监听器可以再次开始使用消息。做这件事的更好的方法是什么。i am using spring-kafka:2.2.8.RELEASE which
浏览 9提问于2020-06-01得票数 1
1回答
DLT消息消耗
、、、、
我们使用的是Spring kafka 2.7非阻塞重试机制。在Spring Kafka重试机制中，kafka监听器消费来自main topic、Retry Topic和DLT topic的消息，我们只希望监听器消费来自main和retry topic的消息。有没有一种简单的设置方法？
因为我们不希望同一个消费者处理DLT消息。D
浏览 1提问于2021-10-14得票数 0
我正在遵循一个简单的指南文档来使用Kafka streams和spring boot (Spring guide) 我很清楚如何传入和传出消息，然后在中间我能够进行一些处理，替换@KafkaListener)，我从一个控制器执行以下操作： template.send("my-topic","hello world"); 我正在使用spring cloud streams，配置如下： spring:isolati
浏览 34提问于2019-01-29得票数 0
我有一个spring boot Kafka监听器，它可以监听单个主题和消费者列表。现在这个spring boot应用程序现在有3个节点。现在，我需要确保列表消息的数量均匀地负载到所有3个节点。我如何在我的应用程序中实现这一点？
浏览 1提问于2021-04-28得票数 0
根据应用程序中消息处理的状态，我试图控制对卡夫卡主题的偏移提交。如果消息成功，则可以提交偏移量。为此，我正在尝试获取方法中的标头，如果是这样，则可以手动确认该消息。spring: stream: contentType: application/json type: kafka</
浏览 0提问于2018-07-03得票数 0
回答已采纳
我有一个可以批量消费消息的Kafka监听器。我也在使用手动提交。如果其中任何一条消息出现问题，我将使用返回语句，而不是提交偏移量(我希望再次处理所有这些消息)。我的问题是- 在Kafka Listener中使用return语句有副作用吗？再次消费相同的消息需要多长时间？ 我正在使用Spring Kafka和SpringBoot。
浏览 34提问于2021-04-26得票数 0
回答已采纳
1回答
使用Spring Boot Kafka -v 2.2.1.RELEASE (使用kafka-clients.jar v 2.3.1) 我正在为我的Kafka代理使用confluent v5.1.2。我有一个基于spring的监听器类(@KafkaListener)，每个消息处理大约需要6-7秒，因为它是一个资源密集型操作。我在这里注意到的是，监听器从未提交过偏移量，并且延迟永久地保持为"5
浏览 20提问于2020-01-23得票数 0
我正在使用Spring-Kafka框架实现来自Kafka主题的消息消费。我正在尝试理解我为我的卡夫卡监听器创建的ConcurrentKafkaListenerContainerFactory的一些用法。@KafkaListener运行良好，但不出所料，在我的场景中，我有多个独立的侦听器，分别侦听多个主题。我想知道我是否可以在我所有的监听器中重用Concurrent
浏览 187提问于2020-04-26得票数 1
回答已采纳
我正在开发一个使用spring-kafka的Kafka监听器的应用程序。我面临的问题是，当Kafka listener没有打开(各种原因，比如Kafka服务器没有打开或关闭)时，spring上下文初始化会失败。如何确保我的应用程序是独立的。
有谁能帮帮忙。
浏览 44提问于2017-09-10得票数 4
回答已采纳
2回答
我正在使用spring boot + spring @KafkaListener。我期望的行为是:我的kafka侦听器在10个线程中读取消息。因此，如果其中一个线程挂起，其他消息将继续读取和处理消息。@Beanspring.kafka.
浏览 0提问于2019-11-16得票数 6
回答已采纳
我是新来的春天卡夫卡。我有一个微服务，它发送消息与kafka密钥，这是一个用户定义的对象。假设消息是由密钥myKey发送的。我想在监听程序中创建一
浏览 1提问于2019-09-26得票数 2
作为Spring和UDP的新手，我花了很多时间来研究这个主题，但没有找到一个好的答案。我需要建立一个监听器，潜在地可以处理大量的消息，并将它们转发给Kafka。
浏览 8提问于2017-04-22得票数 1
我想根据邮件的内容过滤邮件。例如，在使用json formart的消息中，例如{"shipmentType："YAW0"，"shipmentId":"123"，"lat":"999.222"，"log":"888.222"}。如果发货类型为"YAW0"，则应丢弃此消息。我注意到Spring为此提供了RecordFilte
浏览 43提问于2021-09-20得票数 0
我有两个集群设置:站点1上的集群1(3个代理)和站点2上的集群2(3个代理)。使用spring kafka(1.3.6)消费者(一台机器)并通过@KafkaListener注释监听消息。如何为每个集群(c1和c2)实例化多个KafkaListenerContainerFactory，并同时侦听来自这两个集群的数据。
我的监听器应该同时使用来自两个集群的消息。
浏览 1提问于2018-09-24得票数 2
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
