然后，此消息/事件将保存到数据库中。 对于Kafka监听器，我使用了Spring Cloud Stream。Cloud Stream使用者和反应式存储库的正确方式吗？我读了Spring Cloud Stream documentation (for 3.0.0 release)，他们说 Native support for reactive programmingFor backward compatibility you
浏览 40提问于2020-12-15得票数 4
回答已采纳
我正在构建一个基于SpringCloud流的应用程序，交换类型是主题，消息从主题交换发送到2个队列消费者组。场景是这样的：spring.cloud.stream.bindings.output.destination=appointments-request
s
浏览 11提问于2019-07-10得票数 0
1回答
我尝试将Spring Cloud Stream与此topic中描述的函数一起使用。但它不起作用。MessageChannel producer(); cloud: definition: consumer
浏览 20提问于2020-09-13得票数 0
回答已采纳
但是，existing documentation、blog posts和sample code似乎使用了过时的注释(如org.springframework.cloud.stream.annotation.Input这似乎是因为他们依赖于旧风格的Spring Cloud stream应用程序，而不是使用Java functional api (例如，java.util.function.Function)，正如在同一个repo中给出的其他示例(<em
浏览 14提问于2021-11-06得票数 0
回答已采纳
2回答
> <artifactId>spring-cloud-starter-netflix-turbine-stream>
浏览 0提问于2018-08-29得票数 1
2回答
春云巴士-重命名狂犬病队列？
、、、、
有没有办法告诉spring总线重命名它的rabbitmq队列？启动时，它们似乎只是一些随机值，如下所示：试图让spring总线将其重命名为一个更具人类可读性的可预测队列名我尝试在application.yml on for bootRun中添加以下内容： cloud: bindings:
浏览 3提问于2016-10-18得票数 2
回答已采纳
我在微服务方面没有很多经验，也不太明白如何在下面描述的情况下进行。我有两个web服务，一个生产者和一个消费者。它们通过Apache Kafka进行通信，生产者本身定期抛出具有随机id和分数的消息，消费者计算并将每个id的平均分数存储在Map中。=customersspring.cloud
浏览 9提问于2020-11-30得票数 0
我让一个非SCS生产者(使用Spring-Kafka的应用程序)尝试向一个SCS消费者订阅的主题发送一个json序列化对象。放在主题上的信息是-SCS消费者的配置如下。spring.cloud.stream.bindings.input.content-type=appl
浏览 0提问于2017-02-10得票数 1
1回答
我已经构建了一个生产者spring cloud stream应用程序，并将kafka作为活页夹。下面是application.yml：cloud: instanceCount : 1 output:我有两个实例(在单个jvm上运行相同的应用程序)作为消费者。下面是application.yml：clou
浏览 2提问于2016-09-30得票数 0
我正在尝试将单独的Serde放在我的每个消费者身上，而不是所有消费者。例如，这会将Avro反序列化程序添加到我的应用程序中的所有使用者。我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer如果我这样做，它就会起作用 spri
浏览 13提问于2020-10-28得票数 0
回答已采纳
我遇到了这样的情况，我想暂停消费者停止通过spring boot应用程序消费消息，并且消息不应该从队列中丢失，我正在使用amqp和spring cloud stream。https://github.com/spring-cloud/spring-cloud-stream/blob/master/docs
浏览 44提问于2019-03-31得票数 0
我们已经实现了一个应用程序来生成消息和标题，并将其发送到kafka主题。消费者端应用程序正在聆听卡夫卡的主题。消费者端应用程序能够接收有效载荷，但是头不是received.Earlier，我们的头是在有效载荷属性中接收的。为了禁用将报头(包括contentType)嵌入到有效负载中，我们使用了<e
浏览 2提问于2019-05-08得票数 0
我有生产者和消费者春云流应用程序，我们不知道我们将启动哪个应用程序first.either，它可以是生产者还是消费者。当我们在application.properties中为生产者和消费者应用程序声明有关目标(Exchange)、组(队列)的属性时，如果目的地(Exchange)、组(队列)已经存在，请不要再次尝试创建=foodOrders
spring.cloud.stream.bindings.foodOrder
浏览 1提问于2018-12-11得票数 0
回答已采纳
在我的制作人application.properties中，我有spring.cloud.stream.bindings.output.producer.partitionCount=4
我的消费者application.properties看起来像这样spring.clou
浏览 0提问于2016-08-18得票数 0
我正在使用spring云基础设施运行RabbitMq消费者。文件规定如下：应用程序的已部署实例数。必须设置为在生产者端进行分区。在使用和卡夫卡if autoRebalanceEnabled=false时，必须将其设置在消费者端。应用程序的实例索引:
浏览 3提问于2020-06-28得票数 1
回答已采纳
这是spring的配置 cloud: bindings: destinationmessage -> System.out.println("Got it: " + message.getPayload());不过，当我运行这个应用程序时，我可以看到在输出中创建了3个消费者但是，当我检查本地代理中的<
浏览 7提问于2021-04-14得票数 0
回答已采纳
在文档中，有一些提到了“死信队列”，它可以用于消息处理中的异常。但我在这上面找不到更多的地方。我正试图在我的处理管道中配置一个Kafka绑定的死信队列。
浏览 3提问于2016-08-01得票数 1
我正在MVC Controller上编写Spring Cloud契约测试，其中包含带有注释@PreAuthorize("hasRole('ADMIN')")的方法。在方法上的自动生成测试中，根据合同 .get("/api
浏览 45提问于2019-07-11得票数 2
目前使用SpringBoot2.0.1和SpringSecurity5.0.4进行反应应用程序。
谢谢您抽时间见我。更新1：在中上传一个MWE
更新2：我的
浏览 0提问于2018-04-17得票数 2
回答已采纳
1回答
你好，我正在写一个使用spring cloud stream的kafka消费者-生产者。在我的消费者内部，我将我的数据保存到数据库中，如果数据库关闭，我将手动退出应用程序.After重启应用程序，如果数据库仍然关闭，则应用程序再次停止。#Spring Cloud Streams Configurationspring.cloud.str
浏览 33提问于2019-02-19得票数 1
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
