如何在Spring Cloud Stream中使用PollableChannel来接收来自输入的流？谢谢
浏览 9提问于2017-01-26得票数 0
回答已采纳
1回答
我试着用卡夫卡的Springboot云流来建立一个项目。我成功地构建了一个简单的示例，其中一个侦听器从一个主题获取消息，在处理完它之后，它将输出发送到另一个主题。inboundFileEventChannel();
MessageChannel outboundRawLinesChannel();这个例子的问题是，当服务启动时，它不检查主题中已经存在的消息，它只处理启动后发送的消息。：
如果我想在应用程序启动后处理该主题中存在的
浏览 0提问于2018-12-10得票数 1
回答已采纳
' but was actually of type 'org.springframework.cloud.stream.messaging.DirectWithAttributesChannel'#stubrunner.integration.enabled: false To make sure is using Spring Cloud St
浏览 0提问于2020-03-09得票数 0
回答已采纳
1回答
我们有一个spring-boot应用程序(spring-boot-starter-parent-2.0.0.RELEASE)，它使用spring-cloud-starter-zipkin将“span”写入我们也使用了spring-integration (通过spring-boot-starter- integration )，并且我们已经添加了一个带有PollableChannel的集成流，以便在轮询器中使用：public Po
浏览 0提问于2018-07-20得票数 0
1回答
我试图使用来桥接两个Kafka集群(本质上是一个花哨的MirrorMaker实例)，使用bridge应用程序。正如文档中所述，我定义了两个绑定器。卡夫卡-基地1应该是默认的，卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供，例如: app.bridge.spring.cloud.stream.bindings.output.binder=kafka-qa2我的SCDF application.yaml包含两个绑定： cloud
浏览 6提问于2017-02-03得票数 0
回答已采纳
我试着用春天的云流卡夫卡流来阅读卡夫卡。然后，在一分钟的时间窗口内将事件聚合起来，并将其用于不同的主题。然后，我需要从主题中读取聚合事件，并将其写入不同的主题，同时将主题绑定到另一个kafka集群中的不同主题。但是我得到了下面的活页夹例外。org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:182)
... 14 common fr
浏览 0提问于2019-05-17得票数 1
我有一个基于微服务的应用程序，从卡夫卡主题读取消息。当服务关闭时，如果有任何关于该主题的消息正在写入，我希望使用者在下次启动并运行时读取这些消息。但是当服务中断时，我错过了所有的消息。如何让使用者读取在服务关闭时未被读取的消息？spring.cloud.stream.bindings.input.destination=test
<e
浏览 1提问于2017-07-29得票数 1
我有一个有两个分区的“主题”。topic-1input0具有相同的目的地“主题”和相同的组。我的理解是，由于它是一个相同的组，每个主题将自动分配一个分区。
是否可以将特定的分区分配给特定的消息通道？
浏览 6提问于2017-07-27得票数 3
回答已采纳
使用Spring Cloud DataFlow 1.2.2版本，配置如下：spring.cloud.dataflow.applicationProperties.stream.spring
浏览 0提问于2017-07-17得票数 0
回答已采纳
1回答
springBootVersion = '1.4.2.RELEASE' dependencies { compile('org.springframework.cloud:spring-cloud-starter-strea
浏览 1提问于2016-11-25得票数 1
回答已采纳
我正在使用spring云流并试图发布avro消息，但是得到了上述异常，spring.cloud.stream.bindings.feed-output-channel.producer.useNativeEncoding=truespring.cloud.strea
浏览 14提问于2022-01-21得票数 0
回答已采纳
1回答
我在application.properties中指定了但是当我从仪表板部署一个流时，我可以在日志中看到另外，任何其他属性(如Kafka绑定器或zkNodes )都不会从application.properties中读取，但会使用默认值，从而使部署失败。
如何为所有已部署的应用程序/流覆盖这些属性？
浏览 6提问于2017-03-09得票数 0
回答已采纳
1回答
我使用Kafka实现微服务之间的Asyng调用，使用Spring进行日志记录。日志记录是正常的，但是当有消息从Microservice1到Microservice2时，日志记录的消息具有不同的跟踪ID。难道他们不需要有相同的追踪Id但有不同的SpanId吗？有没有特殊的配置？
浏览 2提问于2016-12-02得票数 4
回答已采纳
是否提供通过在cloud.stream @Input("suffix"+"SampleQueueA")和@Input("suffix"+"SampleQueueB")中动态更改队列名称来在两个“队列”之间推送消息 使用消息服务器RabbitMQ的Sprig cloud stream的用例。我尝试通过动态更改队列名称将消息推送到两个不同的队列中。: gues
浏览 27提问于2019-05-26得票数 0
我正在尝试实现Turbine AMQP来合并来自多个服务的所有流到Hystrix Dashboard。 at org.springframework.cloud.<em
浏览 7提问于2016-04-30得票数 5
我想从数据库中获取记录并将其转换为json。这在Spring Cloud Dataflow上运行。
我怀疑我错过了IntegrationFlow上的一些通话。
浏览 1提问于2020-07-30得票数 1
我在spring-云流-schema- 1.2.0.RC1中缺少了AvroSchemaMessageConverter类。我想通过这个链接。<dependency> <artifactId>spring-cloud-stream-schema</artifactId>
<version>
浏览 4提问于2017-04-03得票数 0
回答已采纳
我使用： <dependency> <artifactId>spring-cloud-starter-stream-rabbit我试过这个： spring: config: discovery:
浏览 114提问于2019-12-27得票数 0
回答已采纳
我正在尝试开发一个新的应用程序来在SCDF 2.4.1和Skipper 2.3.1上工作 我从https://github.com/sabbyanandan/stream-programming-models: stream: definition: uppercase
<?>
<groupId>org.springframework.c
浏览 25提问于2020-03-26得票数 0
1回答
spring.cloud.stream.instanceCount，spring.cloud.stream.instanceindex
考虑一下这条管道，兔子sink >filter->transform设置1)对兔子src的预取设置为50。2)使用httpclient将消息发布到本地rest端点，该端点由一个运行的spring微服务实例公开。问题: httpclient ->兔子接收器部分管道之间出现瓶颈，因为我看
浏览 1提问于2018-09-21得票数 0
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号