我的任务是使用Spring Cloud Stream (使用Kafka绑定)。浏览Spring Cloud Stream的Quick Start，并从它使用的配置文件LogSinkConfiguration判断，这里的建议似乎是使用Spring Integration模式，例如@然而，我找到的
浏览 24提问于2019-10-09得票数 1
回答已采纳
在微服务架构中使用Kafka作为消息传递系统，我想知道首选的是Spring Kafka还是Spring Integration Kafka，为什么？另外，我们根据什么因素来决定选择哪一个？
浏览 75提问于2020-04-13得票数 2
我一直在尝试使用Spring Integration的@Router和带有Kafka绑定的Spring Cloud Stream。我的理解是，当您从带有@Router注释的方法返回频道名称的List时，它们应该被生成到目标Kafka主题。但我没有看到正在产生的消息。Spring Integration的@Rou
浏览 16提问于2020-04-06得票数 0
回答已采纳
在使用@StreamListener收听kafka主题之后，在RuntimeException、全局erroChannel或主题特定errorChannel (topic.group.errors)上没有收到任何错误消息>
spring.cloud.stream.bind
浏览 1提问于2019-06-07得票数 0
回答已采纳
/artifact/org.springframework.cloud/spring-cloud-starter-stream-rabbit
// https://mvnrepository.com/artifact
浏览 0提问于2019-07-12得票数 0
e.getCode().getCode() + " " + e.getCode().getDescription(), e); }}
当从消息中提取标头时，会出现异常，有什么最佳方法可以解决这个问题呢？spring.cloud</e
浏览 2提问于2018-04-13得票数 0
回答已采纳
我使用的是Spring Cloud Streams和com.azure.spring:azure-spring-cloud-stream-binder-eventhubs:2.8.0，，我使用的是SupplierThe attempt was made from the following location:
org.springframework.cloud.stream</em
浏览 1提问于2021-09-10得票数 1
当@StreamListener处理失败，Spring Cloud Stream Kafka绑定器尝试将消息重新路由到DLQ时，我得到以下异常。使用Spring Cloud Edgware.SR5。生成消息，发现只有在使用Kafka key时才会发生这种情况。spring.cloud.stream.bindings.my-message-in.destination=my.message.desti
浏览 30提问于2019-03-23得票数 0
回答已采纳
我得到了卡夫卡异常时，尝试卡夫卡主题作为来源stream create --definition ":myDestination > log" --name ingest_from_brokerstream deploy ingest_from_broker --properties "spring.cloud.stream.bindings.input.consumer.headerMode=raw"
当我运行它时，
浏览 1提问于2016-08-02得票数 0
回答已采纳
我正在将一个简单的Kafka消费者应用程序从现有的框架中移出，我觉得spring云流是一种简单的方法。我使用Initializr引导应用程序，它现在使用Spring-Bootv1.3.3和Spring-Cloud-Streamv1.0.0-RC1。但是上面提到的解决方案是到我<e
浏览 4提问于2016-04-11得票数 2
回答已采纳
我使用Spring数据流来设置读取CSV文件的流，使用自定义处理器对其进行转换并对其进行日志记录：
stream create --name testsourcecsv --definition "file=application/json | log --spring.cloud.stream.bindings.input.content-type=application/json" --deploy文件和cs
浏览 8提问于2019-12-03得票数 1
回答已采纳
我们使用Java DSL创建了几个SI流。所有流程都集中在一个Spring启动应用程序中，这使得我们每次添加新流程时都要重新部署该应用程序。如果我们以某种方式将流创建抽象为JSON格式或管道分隔的流指令，我会感到好奇。这样我们就可以动态地创建流并注册它。我已经对此进行了搜索，但一无所获。如果可能的话，请引导我朝着正确的方向去实现它。
浏览 8提问于2020-08-05得票数 1
1回答
(路由器开始处的日志语句永远不会输出)--spring.cloud.stream.bindings.input.destination=delivery-stream.config-enricher
我们尝试
浏览 0提问于2018-11-27得票数 0
回答已采纳
我正在使用spring cloud连接到我的Kafka经纪人。它工作得很好。现在我想通过代码而不是注释来创建我的绑定。有没有一种方便的方法呢？
浏览 1提问于2017-07-16得票数 0
我正在尝试在应用程序启动时使用spring cloud stream向rabbitmq发送消息。使用下面的示例代码。... 9 common frames omitted<?<artifactId>spring-cloud-stream<&
浏览 0提问于2018-06-14得票数 1
2回答
我使用的是spring云数据流服务器本地1.1.4。在application.properties中spring.cloud.dataflow.applicationProp
浏览 4提问于2017-03-09得票数 1
回答已采纳
1回答
什么时候可以使用这些属性？spring.cloud.stream.instanceCount，spring.cloud.stream.instanceindex
考虑一下这条管道，兔子sink >filter->transform设置1)对兔子src的预取设置为50。2)使用httpclient将消息发布到本地rest端点，该端点由一个运行的spring微服务实例公开。因此，理想情况下，
浏览 1提问于2018-09-21得票数 0
我使用SCDF和SpringBoot2.x度量和SCDF指标收集器从我的Spring应用程序中收集度量。我真的不支持收集器有关aggregateMetrics数据的逻辑。"spring.cloud.dataflow.stream.name": "poc-stream",
"spring.cloud.dataflow
浏览 3提问于2018-10-25得票数 1
回答已采纳
我正在尝试运行spring dataflow本地服务器，并为所有应用程序配置rabbitmq绑定器。我在主机172.17.0.2上的docker上运行rabbitmq。java -jar spring-cloud-dataflow-server-local-1.2.3.RELEASE.jar
--spring.cloud.dataflow.applicationProperties.stream.spring.cloud</
浏览 1提问于2017-08-12得票数 0
1回答
我想在Spring引导应用程序中编写一个AWS驱动流消费者。我也不确定Spring是否有对动态的支持，或者我必须使用。根据的说法，org.springframework.integration:spring-integration-aws拥有它(在maven回购中可用)。但是，这个示例使用org.springframework.cloud:spring</
浏览 2提问于2018-01-11得票数 4
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
