1回答
-0.destination=sampleQueuespring.cloud.stream.bindings.sender-out-0.destination=sampleQueuespring</
浏览 5提问于2022-11-10得票数 0
1回答
棘手的是，传出的主题可能还不存在，我需要有机会根据环境变量的要求关闭生产者。UNKNOWN_TOPIC_OR_PARTITION 尝试了不同的生产者属性，但没有成功。我还尝试使用ConditionalOnProperty注释生产者类，但服务类需要该bean。
浏览 35提问于2021-11-15得票数 0
我启动了一个生产者和一个消费者。我可以看到消费者正在消费消息。spring.cloud.stream.bindings.input.destination=
浏览 3提问于2016-09-29得票数 0
1回答
我有一个生产者，具有以下content-type配置 cloud: bindings: destination: lab_csi在消费者端，我使用spring集成(KinesisMessageDrivenChannelAdapter
浏览 55提问于2018-06-19得票数 1
回答已采纳
我有生产者和消费者春云流应用程序，我们不知道我们将启动哪个应用程序first.either，它可以是生产者还是消费者。1.如果生产者首先启动，它需要创建目标和组，并且相同的目的地和组将被消费者使用，而不会再次尝试创建。spring.cloud.stream.bindings.foo
浏览 1提问于2018-12-11得票数 0
回答已采纳
我已经用Artemis活页夹https://github.com/snowdrop/spring-cloud-stream-binder-artemis设置了一个spring cloud stream我有两个应用程序，即生产者和消费者。下面是我的application.yml配置 生产者配置 spring: allow-bean-definition-o
浏览 57提问于2021-10-28得票数 0
我知道如何使用命令式编程方法定义生产者，但我找不到如何使用函数式编程方法定义生产者。我读了Spring Cloud Stream Binder的文档，但只发现如何定义消费者，或者消费者和生产者(例如，从主题中获取信息，转换数据并发送到另一个主题)。因此，我不知道是否可以继续使用像@Input、@Ouptut这样的注释来定义单个处理器，在这一点上我非常困惑，因为库表明这些注释已被弃用，但我找不到示例或文档来定义一个简单的生产者来向特定主
浏览 30提问于2021-01-22得票数 2
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。o.s.c.s.b.k.KafkaMessageChannelBinder :无法使用contentType java.lang.NullPointerException反序列化io.igx.android.Sensor
我有消费者端的spring.cloud.stream.bindings.output.cont
浏览 6提问于2017-03-09得票数 1
是否可以在application.yml中仅为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题我正在使用spring-cloud-stream和kafka-streams绑定器。 在更一般的意义上，这是创建kafka主题的正确方法吗？
浏览 30提问于2020-11-24得票数 0
回答已采纳
生产者服务的配置：spring.cloud.stream.bindings.input.destination=appointments-reply
spring.cloud.stream.rabbit.bindings.output.producer.exchangeType=
浏览 11提问于2019-07-10得票数 0
我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer如果我这样做，它就会起作用 spring.cloud.stream.bindings.scheduler-in-from-external-event.content-type=applicatio
浏览 13提问于2020-10-28得票数 0
回答已采纳
我让一个非SCS生产者(使用Spring-Kafka的应用程序)尝试向一个SCS消费者订阅的主题发送一个json序列化对象。放在主题上的信息是-SCS消费者的配置如下。spring.cloud.stream.bindings.input.content-type=application&#
浏览 0提问于2017-02-10得票数 1
1回答
我已经构建了一个生产者spring cloud stream应用程序，并将kafka作为活页夹。下面是application.yml：cloud: instanceCount : 1 output:下面是application.yml：cloud: bindings:
i
浏览 2提问于2016-09-30得票数 0
使用spring-cloud-stream的kafka绑定器，如何配置并发消息消费者(在单个消费者jvm中)？s-c-s文档根本没有提到spring.cloud.stream.bindings.*.concurrency，尽管这在我上面描述的用例中似乎很重要。使用生产者配置 cloud: bindings:
c
浏览 2提问于2016-03-08得票数 7
我有一个运行在服务器上的RabbitMQ消息代理，我正在尝试使用配置一个生产者和一个消费者。我的生产者每秒钟都在队列中创建消息，而我的使用者以相同的速度读取它们。但是，如果我停止了我的使用者，而生产者一直在推消息，当我再次重新启动我的使用者时，它将无法检索在它被关闭的那一段时间内创建的消息，只会收集从启动时产生的消息。这是我的消费者财产： stream: input:
destin
浏览 0提问于2020-10-16得票数 0
回答已采纳
我正在尝试在spring cloud stream中实现延迟消息(不使用rabbitmq插件)，但它不起作用spring.cloud.stream.bindings.o
浏览 18提问于2019-08-14得票数 0
我是和Kafka的新手，我正在寻找一个很好的例子来使用来自kafka主题的json消息。
浏览 6提问于2017-03-06得票数 1
回答已采纳
1回答
我尝试将Spring Cloud Stream与此topic中描述的函数一起使用。但它不起作用。MessageChannel producer(); cloud: definition: consumer
stre
浏览 20提问于2020-09-13得票数 0
回答已采纳
1回答
弹簧云函数路由
、、、、
我正试图通过实现Spring云功能来创建一个kafka。spring.cloud.stream.bindings.articleAggregated.contentType=application/jsonspring.cloud.stream</em
浏览 4提问于2021-11-17得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号