我们让多个应用程序使用者收听相同的kafka主题，并且生产者在向主题发送消息时设置消息头，以便特定实例能够评估标头并处理消息。TestObj message) {}
在SpringCloudStream3.0.0中，@StreamListener被废弃了，我无法在函数中找到与
浏览 11提问于2021-09-16得票数 5
我有一个spring引导应用程序，我正在使用kafka主题的消息，并将消息存储在DB中。我有一个处理DB fail的要求，如果DB关闭，则不应该提交该消息，并在一段时间后暂停消费消息，然后监听器可以再次开始使用消息。做这件事的更好的方法是什么。i am using spring-kafka:2.2.8.RELEASE which is internally using ka
浏览 9提问于2020-06-01得票数 1
我们正在考虑在我们的消息传递中使用Kafka，我们的应用程序是使用Spring开发的。因此，我们计划使用spring-kafka。另一方面，我们有一个<em
浏览 0提问于2018-06-29得票数 5
回答已采纳
1回答
DLT消息消耗
、、、、
我们使用的是Spring kafka 2.7非阻塞重试机制。在Spring Kafka重试机制中，kafka监听器消费来自main topic、Retry Topic和DLT topic的消息，我们只希望监听器消费来自main和retry topic的消息。因为我们不希望同一个消费者处理DLT消息。DLT也会被另一个进程使用，以发送请求的通知。
浏览 1提问于2021-10-14得票数 0
我有一个可以批量消费消息的Kafka监听器。我也在使用手动提交。如果其中任何一条消息出现问题，我将使用返回语句，而不是提交偏移量(我希望再次处理所有这些消息)。我的问题是- 在Kafka Listener中使用return语句有副作用吗？再次消费相同的消息需要多长时间？ 我正在使用Spring Kafka和SpringBoot。
浏览 34提问于2021-04-26得票数 0
回答已采纳
根据应用程序中消息处理的状态，我试图控制对卡夫卡主题的偏移提交。如果消息成功，则可以提交偏移量。为此，我正在尝试获取方法中的标头，如果是这样，则可以手动确认该消息。spring: stream: contentType: application/json type: kafka
defaultCandid
浏览 0提问于2018-07-03得票数 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秒，因为它是一个资源密集型操作。我在这里注意到的是，监听器从未提交过偏移量，并且延迟永久地保持为"550“。 正因为如此(我认为)，消息
浏览 20提问于2020-01-23得票数 0
我正在遵循一个简单的指南文档来使用Kafka streams和spring boot (Spring guide) 我很清楚如何传入和传出消息，然后在中间我能够进行一些处理，替换@KafkaListener{KAFKA_CONSUMER_CONCURRENCY:3} destination: my-topic binderisolation.level: read_commit
浏览 34提问于2019-01-29得票数 0
我正在使用Spring-Kafka框架实现来自Kafka主题的消息消费。我正在尝试理解我为我的卡夫卡监听器创建的ConcurrentKafkaListenerContainerFactory的一些用法。@KafkaListener运行良好，但不出所料，在我的场景中，我有多个独立的侦听器，分别侦听多个主题。我想知道我是否可以在我所有的监听器中重用ConcurrentKafkaListenerContainerFacto
浏览 187提问于2020-04-26得票数 1
回答已采纳
2回答
我正在使用spring boot + spring @KafkaListener。我期望的行为是:我的kafka侦听器在10个线程中读取消息。因此，如果其中一个线程挂起，其他消息将继续读取和处理消息。@Beanspring.kafka.listener.concurren
浏览 0提问于2019-11-16得票数 6
回答已采纳
总的来说，我对Java、Spring和Kafka都很陌生。ArrayBlockingQueue，我希望它将Kafka的消息添加到监听器中。我遇到的问题是，我不知道如何将一个ArrayBlockingQueue传递给侦听器，因为Spring在幕后处理侦听器的实例化和运行。我需要这个阻塞队列，以便监听器之外的另一个对象可以访问消息并处理它。例如，在我的主要内容中：
@SpringBoo
浏览 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 boot Kafka监听器，它可以监听单个主题和消费者列表。现在这个spring boot应用程序现在有3个节点。现在，我需要确保列表消息的数量均匀地负载到所有3个节点。我如何在我的应用程序中实现这一点？
浏览 1提问于2021-04-28得票数 0
我使用和功能接口来处理我的kafka处理。application.yml (相关部分) cloud: kafka: brokersgroup: input-group-1
浏览 1提问于2020-04-22得票数 0
回答已采纳
Actor本身是一个接收消息、原子处理消息并向下一个Actor发送消息的实体。参与者异步工作，它们之间不传输应用程序上下文，也不能直接访问另一个Actor的实例。每个演员对另一个因素一无所知。在分布式系统中，我们通常不能观察到一致性，同时使系统具有容错性。因此，我们不能保持消费者之间的消息顺序。
然而，Kafka引入了诸如使用交易机制这样的功能。我读到Kafka现在支持使用新的事务性API在多个分区中进行原子写入。这允许生产者将<em
浏览 6提问于2022-11-28得票数 0
回答已采纳
我在一个spring boot项目中工作，在这个项目中，我使用spring-kafka依赖项消费来自kafka主题的消息。这是我的监听器，它运行良好：
@KafkaListener(topics = "${mytopic.name}", containerFactory = "kafkaEventListenerObjectContainerFactory// my code here...
浏览 16提问于2021-07-26得票数 0
我有一个用例，在这个用例中，我有3个Kafka消费者在写一个主题，每个消费者中的消息需要按顺序处理。以防万一，如果其中一个消费者存在滞后，则需要更早处理的消息将被丢弃(写入条件)。那么，有没有办法可以维持这些消息的顺序呢？
浏览 2提问于2020-06-04得票数 0
注意，我没有显式地定义任何bean，我将所需的bean创建留给了spring boot。 我想知道我的理解是否正确。我希望并行地使用来自有多个分区的主题的消息，比如3。那么，如果我在application.yml文件中配置它，如下所示就可以了。我已经尝试了下面的配置，并看到创建了3个消费者。spring: consumer: key-deserializer: org.apache.<em
浏览 39提问于2019-10-08得票数 2
回答已采纳
1回答
所建议的构建它的架构是使用spring云流。我在许多文章中读到，您可以将spring云消息传递系统移植到其他系统。这意味着，我以后也可以将IBM更改为kafka，但可以在类路径上提供绑定器实现。我使用rabbitmq构建了一个Spring应用程序，我在应用程序中使用的特性是belo，
生产者和监听器配置都是向上和向下的，这意味着我可以创建一个队列，它的交换和绑定路由密钥使用代码如果我使用
浏览 1提问于2018-11-25得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
