我遇到了这样的情况，我想暂停消费者停止通过spring boot应用程序消费消息，并且消息不应该从队列中丢失，我正在使用amqp和spring cloud stream。https://github.com/spring-cloud/spring-cloud-stream/blob/master/docs/src/main&#x
浏览 44提问于2019-03-31得票数 0
我一直在玩spring云流(1.0.BUILD-使用kafka绑定程序的快照)，并注意到在离线的消费者中，发送的任何消息都会丢失。当我启动消费者时，它不会处理发送给kafka的积压请求。
浏览 0提问于2016-03-06得票数 4
回答已采纳
我有一个rabbitmq队列和两个spring cloud spring消费者。我希望每个消费者都能按顺序处理消息。我认为当consumer1发送确认时，consumer2会收到第二条消息，所以我预计message1，message2在每个消费者中都是按顺序处理的。pass ------------------------>
consumer2: message2 messa
浏览 15提问于2017-07-13得票数 1
回答已采纳
我们使用spring云流来消耗和生成Rabbitmq的消息。我们的生产者和消费者应用程序都没有使用spring</e
浏览 0提问于2019-01-25得票数 0
回答已采纳
1回答
如何在spering云流中使用项目反应堆背压功能和kafka粘合剂？String>> processor() {} 如果我使用这种方式，那么发布者发送消息有1秒的延迟，但是消费者消费消息没有任何延迟。可以在cunsumer上使用backperessure和spring cloud stream
浏览 52提问于2021-04-19得票数 2
回答已采纳
我正在尝试实现一个PollableConsumer，当我在SpringBoot应用程序中碰到一个端点时，它会在特定条件下开始轮询来自卡夫卡的消息。我尝试了多种方式触发计票在一定条件下，但显然，它只有当它是从卡夫卡主题不断轮询时才能起作用。(就像spring云流文档中的所有示例一样)public interface CustomProcessor { PollableMessageSo
浏览 1提问于2019-03-29得票数 2
回答已采纳
这不是一个大问题，但我很好奇，一些额外的流消费者来自哪里，如果这是一个设置，我可以改变。}
不过，当我运行这个应用程序时，我可以看到在输出中创建了3个消费者但是，当我检查本地代理中的<em
浏览 7提问于2021-04-14得票数 0
回答已采纳
我们的微服务使用JDK 8，Spring Cloud Stream API with Spring Boot 1.5.2 messages将消息生成到Kafka队列。对于Consumer API，我们使用Spring Kafka 1.1.2.RELEASE，特别是@KafkaListener。消息类型为应用程序json在JDK 8<em
浏览 0提问于2017-06-20得票数 0
1回答
我的Spring Cloud Stream应用程序中有一个断路器。当电路正在改变状态，并且我的流消费者是匿名的(不在组中)时，它可以很好地暂停/恢复流。当消费者属于一个组时，暂停流可以很好地工作，但是恢复会被“忽略”，最终以超时结束并离开组。有没有解释为什么会出现这种不一致的行为？
Spring云流版本为3.0.8.RELEASE。一旦电路关闭并恢复流，
浏览 0提问于2021-01-23得票数 0
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。在使用消息时会发生以下错误：我有消费者</e
浏览 6提问于2017-03-09得票数 1
2回答
卡夫卡用户断路器
、、、
有没有一种方法来实现一个断路器模式与弹簧卡夫卡的基础上的消费者。我想知道，在实现我的Spring用户时，如果基于某个外部系统处理数据失败并引发网络错误，是否有可能停止使用记录。然而，如果网络问题得到解决，消费者应该再次正常处理。
浏览 11提问于2018-01-02得票数 6
动态路由是否等同于spring云流中的动态目标绑定？每只兔子动态路由所有生产者发布到同一队列，生产者配置routingKeyExpression，消费者监听器配置bindingRoutingKey，exchange将消息路由到匹配的bindingKey。这可以使用流桥接或BinderAwareChannelResolver来完成吗？如果不是，spring如何处理这一点，以防有人想要从兔转到其他经纪人。
浏览 5提问于2021-05-14得票数 0
2回答
春云流时有很多不同的事件类型
、、、、
我想要一个关于春云流技术使用的建议。目前，我的服务使用spring引导，并实现了一些基于事件的方法。但是事件不是发送给某种代理，而是由处理程序在单独的线程中处理。我对春云流技术很感兴趣。但问题是，以这种方式声明配置中的所有消费者听起来很痛苦： public Consumer<Menu> menuConsumer(){
return menu -> log.info哪里有办法对<em
浏览 10提问于2022-09-26得票数 0
我们有一个很好的解决方案，如预期的那样工作：( 1)使用MetaDataStore检查来自消费者端的重复消息(offsetId + partitionId + topicName)，使用上面的解决方案，我们没有任何消息丢失和重复处理。但是现在我们发现有一个属性(producer.sendOffsetsToTransaction) Kafka帮助我们修复来自消费者端的重复处理，而没有任何元存储逻辑。现在我们还不确定如何使用这个属性.sendOffsetsToTransaction来处理spring<
浏览 0提问于2019-03-27得票数 0
回答已采纳
我有一个春季云流卡夫卡消费者服务，在那里确认是手动完成的。提供一个固定的消费群体。spring.cloud.stream.bindings.input.group=sampleconsumergroup
重置集和spring.cloud.stream.kafka.bindings.input.consumer.resetOffsets=true spring.cloud.stream.kafka.bindings.input.consumer.startOffset=l
浏览 2提问于2019-03-06得票数 1
回答已采纳
我用的是春云流卡夫卡。我正在启动两个具有相同组名的消费者应用程序实例( testGroup )，使用来自具有单个分区的Kafka主题testTopic的消息，我期望其中一个消费者实例使用来自Kafka主题的消息，而另一个实例不使用任何东西这是我的财产
spring.cloud.stream.bindings.input.group
浏览 6提问于2016-11-15得票数 0
目前我在同一个Spring Boot应用程序中配置了生产者和消费者，但奇怪的是，触发消息的Spring云流并没有通过Kafka (我使用kafka-console- consumer来监控消息)，但是消费者仍然接收消息如果我移除应用程序中的consumerHandler (@StreamListener)，生产者会成功地将消息发送到Kafka。 对此有什么配置吗？
浏览 30提问于2021-03-21得票数 1
回答已采纳
我正在使用中的卡夫卡暂停和恢复功能。
我想知道这种暂停是否发生在一个消费者组中的所有消费者身上？我还在这里读到，在Kafka Server上为消费者组保留了暂停状态。
浏览 15提问于2017-07-22得票数 5
1回答
我正在使用@StreamListener (spring云流)来使用来自主题(输入通道)的消息，进行一些处理并保存到某些缓存或数据库中。我的要求是，如果DB在处理所消耗的消息时下降，我希望暂停主使用者(输入-通道)，并开始从另一个主题(input 56-channel)消费，并且一旦它从input 56-通道消费了所有消息(不多)，我想再次恢复主使用者
浏览 3提问于2021-10-26得票数 0
回答已采纳
我正在尝试处理一个有两个或更多消费者的案例，侦听一个仅包含一个分区的公共主题。我暂停了其中一个消费者，在此期间，其他未暂停的消费者应该能够从该主题中获取消息。我观察到，只有当暂停的消费者恢复时，只有其他活动消费者中的一个才能获得消息。我如何通过spring kakfka来实现这一点。我使用的是Spring kafka 2.0.0.M2。
浏览 0提问于2017-08-03得票数 1
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
