1回答
我正在尝试用spring-cloud-stream开发amqp的一部分。我不能在rabbitMQ队列中侦听，如果没有交换(我不能以这种方式更改)，我如何实现一个只针对一个队列的侦听器？？这是我的app-properties.yml cloud: definition: inputCollector default
浏览 12提问于2021-03-19得票数 1
使用Spring Cloud DataFlow 1.2.2版本，配置如下：spring.cloud.dataflow.applicationProperties.stream.sp
浏览 0提问于2017-07-17得票数 0
回答已采纳
我想用Confluent Schema Registry和Avro Schema演进测试Spring Cloud Stream，以便将其与我的应用程序集成。我发现Spring Cloud Stream不支持到Confluent Schema Registry的安全连接，而且实现仍然非常基础。因此，我决定将Confluent Schema Registry Client与Spring Kafka结合使用，用于模式注册部分，并使用Spring Cl
浏览 29提问于2019-04-25得票数 1
1回答
我是Spring和RabbitMQ的新手。我正在尝试生成和使用来自兔子MQ的消息。我在为生产者和使用者配置exchange名称和队列名称时遇到了困难。下面是application.propertiesspring.rabbitmq.addresses=amqp://user:pass@localhost:5672/
s
浏览 7提问于2022-03-29得票数 0
回答已采纳
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。cloud stream，我不知道如何注入这两个参数。目前，我将"basic.auth.user.info"和"basic.auth.credentials.source"放在application.yml文件中的"spring.cloud.<
浏览 21提问于2019-04-16得票数 2
回答已采纳
我有一个有两个分区的“主题”。topic-1input0具有相同的目的地“主题”和相同的组。是否可以将特定的分区分配给特定的消息通道？
浏览 6提问于2017-07-27得票数 3
回答已采纳
我正在尝试修改此Spring Cloud Stream tutorial中的示例发送器，以更改默认的发送间隔。
浏览 19提问于2020-06-19得票数 1
回答已采纳
1回答
我们使用弹簧云蒸汽与RabbitMQ粘合剂。我查了一下PR 。但是这些选项都是私有的，我没有看到任何侦听器或拦截器。
浏览 5提问于2020-08-11得票数 0
回答已采纳
我只是从spring云文档中创建hello应用程序，但并不真正理解。我的应用程序上有q.test (现有的)，但是当我使用这个代码和配置时，我的应用程序总是创建新的队列q.test.anonymous.someRandomString。 return value.toUpperCase(); }
application.yml
spring.cloud.
浏览 2提问于2020-02-07得票数 0
回答已采纳
我已经成功地使用Spring Cloud Stream Kafka Binder (org.springframework.cloud:spring-cloud-starter-stream-kafka:3.0.1.RELEASE)和Spring Cloud Azure Event Hubs (com.microsoft.azure:spring-cloud-starter-azure-eventh
浏览 23提问于2020-04-29得票数 0
一旦我为websocket broker添加了配置，Scs的MessageConverter就不再被使用了。我在中创建了一个简化的例子来演示这个问题--参见提供的单元测试。
浏览 20提问于2020-03-01得票数 0
我正在使用spring-cloud-starter-stream-kafka创建一个Kafka消费者绑定，并将spring.cloud.stream.bindings.input.consumer.autoStartup配置为false (https://cloud.spring.io/spring-cloud-static/spring-<
浏览 68提问于2020-06-25得票数 0
回答已采纳
is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.cloud.stream.test.binder.MessageCollector: Failed to instantiate [org.springframework.cloud.stream.test.binder.MessageCollector]: Factory method(Ljava/lang
浏览 20提问于2017-02-17得票数 1
我正在使用spring云流并试图发布avro消息，但是得到了上述异常，spring.cloud.stream.bindings.feed-output-channel.producer.useNativeEncoding=truespring.cloud.strea
浏览 14提问于2022-01-21得票数 0
回答已采纳
Cloud Streams和Kafka Streams时，所有属性似乎仅通过资源文件夹中的application.properties或application.yml文件输入 spring.cloud.stream.bindingsdestination: data2 contentType: application/jsonspring.cloud.stream.k
浏览 25提问于2019-01-31得票数 1
我的application.properties：spring.cloud.stream.bindings.input.consumer.headerMode=rawspring.<em
浏览 1提问于2017-07-29得票数 1
我在应用程序A中有producer，配置如下，spring.cloud.stream.bindings.packageVersionUpdatesPublishChannel.destination=fabric-exchange
spring.cloud.stream.bindings.packageVersionUpdatesPublishChannel.producer.requiredGroupsspring.c
浏览 1提问于2019-05-30得票数 0
我使用： <dependency> <artifactId>spring-cloud-starter-stream-rabbit我试过这个： spring: config: discovery:
浏览 114提问于2019-12-27得票数 0
回答已采纳
2回答
根据spring云文档，它应该使用autoCommitOffset 来完成。spring.cloud.stream.kafka.binder.brokers=${KAFKA_BROKER_LIST}
浏览 7提问于2020-05-14得票数 1
回答已采纳
云服务器
ICP备案
即时通信 IM
云直播
对象存储
腾讯云开发者
