Spring Cloud Stream -功能供应商未进行轮询
Spring Cloud Stream是一个用于构建消息驱动的微服务应用程序的框架。它提供了一种简化的方式来开发和部署基于消息传递的应用程序，使开发人员能够更专注于业务逻辑而不是底层的消息传递细节。
Spring Cloud Stream的主要特点包括：
- 消息驱动：Spring Cloud Stream基于消息传递模型，通过消息队列或消息中间件实现不同服务之间的通信和协作。
- 松耦合：通过使用消息传递，不同的服务可以独立地进行开发、部署和扩展，彼此之间没有直接的依赖关系。
- 可插拔：Spring Cloud Stream提供了一种可插拔的架构，可以方便地切换不同的消息中间件实现，如Kafka、RabbitMQ等。
- 易于测试：由于服务之间通过消息进行通信，可以更容易地进行单元测试和集成测试，以确保系统的可靠性和稳定性。
Spring Cloud Stream适用于以下场景：
- 异步通信：当需要在不同的服务之间进行异步通信时，可以使用Spring Cloud Stream来简化消息传递的开发和管理。
- 事件驱动架构：当需要构建基于事件驱动的架构时，Spring Cloud Stream可以帮助开发人员更好地处理事件的传递和处理。
- 流处理：当需要进行实时的流处理和数据分析时，Spring Cloud Stream可以与流处理框架（如Spring Cloud Data Flow）结合使用，实现复杂的数据处理逻辑。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq 腾讯云提供的消息队列服务，可用于实现分布式系统之间的高可靠、高可用的消息传递。
- 腾讯云云函数 SCF：https://cloud.tencent.com/product/scf 腾讯云的无服务器计算服务，可用于快速构建和部署基于事件驱动的应用程序。
- 腾讯云流计算 TDSQL-C：https://cloud.tencent.com/product/tdsqlc 腾讯云的流计算服务，可用于实时的流处理和数据分析。
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估和决策。
相关·内容
我试图了解Spring Cloud Streams的新功能模型是如何工作的，以及配置在幕后是如何工作的。
我无法理解的属性之一是spring.cloud.stream.source。
这个财产到底意味着什么？
我无法理解：
注意，前面的示例没有定义任何源函数(例如，供应商bean)，使框架没有创建源绑定的触发器，在配置包含函数bean的情况下，这将是典型的。因此，要触发源绑定的创建，我们使用spring.cloud.stream.source属性，您可以在其中声明源的名称。提供的名称将用作创建源绑定的触发器。
如果我不需要Supplier怎么办？
源绑定到底是什么?为什么它很重要?
如
浏览 1提问于2021-09-16得票数 3
回答已采纳
我的应用程序由一个带有POST方法的REST控制器组成，用于提交我必须使用生成器发送到主题的数据。 这是控制器 @RestController
@RequestMapping("/producer/v1")
public class ApiController {
@Autowired
Producer producer;
@ApiOperation(value = "Invia un messaggio al topic", response = String.class)
@ApiResponses(value = {
浏览 82提问于2021-08-25得票数 0
我正在尝试使用Spring Cloud Function和Kafka实现供应商。我需要一个供应商应该发布后，每10秒和其他应发布后，每30秒。我可以从文档中看到，我可以使用spring.cloud.stream.poller.fixed-delay属性来更改延迟。
但我需要为每个主题设置不同的延迟。有什么办法可以做到吗？
浏览 6提问于2021-04-29得票数 0
我正在尝试使用spring cloud stream在kafka上发送和接收消息。这方面的示例使用了一个使用时间戳作为消息的简单示例。当我在上遇到这个拦截器时，我正试图更深入地了解现实世界的应用程序
“使用@InboundChannelAdapter批注的方法不能接受任何参数”
我试着这样使用它：
@InboundChannelAdapter(value = ChannelManager.OUTPUT)
public EventCreated createCustomerEvent(String customerId, String thingId) {
return new Even
浏览 0提问于2017-07-27得票数 0
在开发一个新的CDF应用程序时，我注意到@EnableBinding已被弃用，因此我使用Supplier bean实现了一个MessageSource @Bean
public Supplier<Flux<Message<LogRecord>>> getLogs() { 为了测试，我在我的Source和File Sink之间创建了一个流。这两个服务都很好，但他们拒绝交流。我可以看到Source写入流，Sink侦听，但它们表现得好像它们不在同一个通道上。 最后，我修改了代码以使用@EnableBinding和@PollableSource，一
浏览 24提问于2021-09-16得票数 0
我知道如何使用命令式编程方法定义生产者，但我找不到如何使用函数式编程方法定义生产者。 我读了Spring Cloud Stream Binder的文档，但只发现如何定义消费者，或者消费者和生产者(例如，从主题中获取信息，转换数据并发送到另一个主题)。 因此，我不知道是否可以继续使用像@Input、@Ouptut这样的注释来定义单个处理器，在这一点上我非常困惑，因为库表明这些注释已被弃用，但我找不到示例或文档来定义一个简单的生产者来向特定主题发送信息。 谢谢! 文档链接：https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3
浏览 30提问于2021-01-22得票数 2
我有一个常规的java Function；我试图绑定它：
它对web端点的输入
它的输出到一个卡夫卡主题。
当我在web上下文中使用我的函数时，它总是将Function的结果值单独返回给web客户机。我能做这样的事吗
spring.cloud.stream.bindings.input.binder=web
spring.cloud.stream.bindings.output.binder=kafka
我目前甚至试图将Function分解为2：
它的输入绑定到web客户端，其输出动态绑定到第二个函数(使用spring.cloud.stream.sendto.destina
浏览 1提问于2019-11-29得票数 4
回答已采纳
我有一个侦听器，它正在侦听UDP数据包，在接收和处理数据之后，希望将它流到一个主题(目前是Kafka)。
我已经成功地运行了一个Spring Cloud Stream Kafka Binder生产者的示例程序。
@Bean
public Supplier<PacketDataPojo> data() {
return () -> {
PacketDataPojo pdp = new PacketDataPojo(UUID.randomUUID().toString());
log.info("Current data {}&#
浏览 0提问于2021-12-01得票数 0
回答已采纳
我想每15分钟批量消费一次消息。为此，我设置了这些属性， spring.cloud.stream.kafka.binder.consumer-properties.max.poll.records=5000000
spring.cloud.stream.kafka.binder.consumer-properties.fetch.max.wait.ms=900000
spring.cloud.stream.kafka.binder.consumer-properties.fetch.min.bytes=500000000 当我将此属性spring.cloud.stream.kafka.bin
浏览 131提问于2021-09-22得票数 0
回答已采纳
我试图从SCDF向中添加一个oracle驱动程序。对于来说，这应该是一个简单的任务，但在运行时，我总是得到一个
org.springframework.integration.jdbc.JdbcPollingChannelAdapter.setMaxRowsPerPoll(int)‘：’NoSuchMethodError：'void NoSuchMethodError
这是我的主修班：
package com.example.sourcejdbcora;
import org.springframework.boot.SpringApplication;
import org
浏览 22提问于2022-05-16得票数 0
回答已采纳
我正在为应用程序编写测试。这有一个来自topicA的topicA读数。在测试中，我使用KafkaTemplate发布消息，并等待KStream日志的出现。
测试引发以下异常：
java.lang.ClassCastException: class com.sun.proxy.$Proxy143 cannot be cast to class org.springframework.messaging.MessageChannel (com.sun.proxy.$Proxy143 and org.springframework.messaging.MessageChannel are in un
浏览 4提问于2020-01-30得票数 1
回答已采纳
我正在做Spring Cloud Stream Apache Kafka的例子。我开发的代码参考自：https://www.youtube.com/watch?v=YPDzcmqwCNo。 org.springframework.messaging.MessageDeliveryException: failed to send Message to channel 'pvout'; nested exception is org.springframework.messaging.converter.MessageConversionException: Could not
浏览 70提问于2020-04-18得票数 1
回答已采纳
通过下面的配置和场景，当到达maxAttempts时会发生什么？
具有Kafka绑定和以下属性的：
spring.cloud.stream.bindings.input.consumer.maxAttempts=3
spring.cloud.stream.kafka.bindings.input.consumer.autoCommitOffset=true
spring.cloud.stream.kafka.bindings.input.consumer.autoCommitOnError=false
spring.cloud.stream.kafka.bindings.inp
浏览 4提问于2017-07-13得票数 1
回答已采纳
我有一个用于探索中新添加的函数的沙箱，但是在一个应用程序中使用函数和供应商遇到了一个问题。
在代码中，我使用了中描述的示例。
首先，我在项目Function<String, String>中添加了相应的spring.cloud.stream.bindings和spring.cloud.stream.function.definition属性。一切正常，我发消息到my-fun-in卡夫卡主题，应用程序执行功能和发送结果到my-fun-out主题。
然后，我将Supplier<Flux<String>>添加到具有相应spring.cloud.stream.bin
浏览 2提问于2020-01-15得票数 2
回答已采纳
我正在尝试使用单个绑定来消费来自多个主题的消息，并且只是简单地打印。但由于某些原因，我只能从第一个主题中获得消息。我是否必须以不同的方式指定属性。我在这个博客https://spring.io/blog/2019/12/03/stream-processing-with-spring-cloud-stream-and-apache-kafka-streams-part-2-programming-model-continued上关注了多路话题的讨论。 // My properties
spring.cloud.stream.bindings.routeRequests-in
浏览 25提问于2021-09-10得票数 1
回答已采纳
1回答
我的问题是如何使用Spring Cloud Stream Kafka管理多实例。 让我解释一下，在Spring Cloud Stream微服务上下文(eureka，configserver，kafka)中，我希望拥有相同微服务的两个实例。当我在GIT Repository中更改配置时，configserver (通过webhook)会将一条消息推送到Kafka主题中。 如果我在我的微服务中使用相同的group-id，那么两个实例中只有一个会收到通知，并重新加载他的spring上下文。但我需要刷新所有实例... 因此，为了做到这一点，我配置了一个唯一的组id：${spring.applicat
浏览 44提问于2020-07-17得票数 2
回答已采纳
我有一个使用Spring、使用spring-cloud-function和spring-cloud-stream-binder-kafka-streams编写的Kafka流处理应用程序。处理几个流的方法被注释为@Bean，因此它应该由spring-cloud-function (而不是使用@StreamListener)来获取。当此方法返回一个BiFunction时，它可以工作。但是当我把它当作普通的Kotlin lambda时，它不会被Spring捕获:应用程序会立即启动，因为它发现没有任何函数可以运行。
从我在中可以看到的情况来看，这应该是可行的。
下面是有效的声明：
@Bean
fun
浏览 9提问于2019-11-06得票数 0
回答已采纳
我有一个使用spring cloud stream的消费者应用程序。这个应用程序正在使用队列中的消息(Kafka)，并且每条消息应用程序向4个不同的服务器发出4个不同的HTTP调用，其中一个非常慢(10秒应答)。当队列充满消息时，例如6000，应用程序会崩溃，原因有几个(1 - netty耗尽直接内存，2-我们正在使用reactor，线程池变空)。
有没有办法通过spring-cloud-stream或者kafka来限制消费端的消费速度？像每秒最大消息数这样的东西会更好。
这里可以看到kafka (application.yml)的配置。
spring:
kafka:
bootst
浏览 28提问于2020-02-12得票数 2
回答已采纳
当消费者在消息处理期间并且在手动ack工作之前抛出异常republishToDlq时，但是原始队列消息总是处于nack状态。 环境 Spring Boot：2.1.11.RELEASE Spring Cloud：Greenwich.SR4 Spring Cloud Stream：Fishtown.SR4 spring-cloud-stream-binder-rabbit：2.1.4.RELEASE Yaml配置 spring:
cloud:
stream:
bindings:
input:
binder: rabbit
浏览 11提问于2020-01-17得票数 0
回答已采纳
我们进行了集成测试，最终将多条消息发送到同一个目的地，但有许多不同的组。在rabbitMQ术语中，相同的交换具有不同的主题。
spring.cloud.stream.bindings.userEdited-out-0.destination=user.exchange
spring.cloud.stream.rabbit.bindings.userEdited-out-0.producer.routing-key-expression='user-edited.v1'
spring.cloud.stream.bindings.userEdited-out-0.content-t
浏览 4提问于2022-05-12得票数 1
回答已采纳
1回答
是否可以使用两个函数，其中第一个函数的输出是第二个函数的输入？
我的职责：
@Configuration
public class StringStream {
@Bean
public Supplier<Flux<String>> stringSupplier() {
return () -> Flux.interval(Duration.of(1L, ChronoUnit.SECONDS))
.map(v -> RandomStringUtils.randomAlphabetic(10))
浏览 2提问于2021-01-06得票数 0
1回答
我正在尝试构建一个Java应用程序，该应用程序可以发布和获取来自合流Cloud的消息。
我跟随将一条卡夫卡消息发布到合流云中，它可以工作。
以下是实施情况
KafkaController.java
package com.seroter.confluentboot.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
浏览 3提问于2020-11-19得票数 5
回答已采纳
Spring Cloud Stream的参考手册中提到，您可以使用"spring.cloud.stream.kafka.binder.headers“属性来设置所有绑定的头部。有没有办法为特定的绑定设置头部？例如，如下所示：
spring.cloud.stream:
bindings:
input:
destination: input-topic
headers: header-for-input-only
output:
destination: input-topic
headers: header-for-ou
浏览 8提问于2016-09-27得票数 0
回答已采纳
给定一个在Spring Cloud Stream函数中生成消息的Supplier函数，例如：
@Bean
Supplier<Flux<Message<PayLoad>>> sendMessage() {
return () -> getMessageSink().asFlux().log();
}
or this version
@Bean
Supplier<Flux<PayLoad>> sendMessage() {
return () -> getMessageSink().asFlux().log
浏览 4提问于2021-08-26得票数 0
1回答
春云流和动物园管理员
、、、、
我有两份申请：
第一部是用卡夫卡写的信息。
第二个接收所有这些消息。
我配置了spring.cloud.stream.kafka.binder.brokers和spring.cloud.stream.kafka.binder.defaultBrokerPort。一切都很好。
在文档中，我看到spring.cloud.stream.kafka.binder.zkNodes和spring.cloud.stream.kafka.binder.defaultZkPort定义了卡夫卡绑定器可以连接到的ZooKeeper节点列表。
据我理解，我只需要将我的应用程序连接到kafka。所以你能
浏览 0提问于2016-10-28得票数 0
排除后
<exclusion>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactId>
</exclusion>
我正在犯错误：
java.lang.IllegalArgumentException:没有为基于注释的端点定义任何轮询器，并且上下文中也没有默认的轮询器可用。
我只有one QueueChannel (也有MessageAggregator -可能充当队列？)，
浏览 2提问于2021-04-29得票数 0
我们有一个需求，当我们使用来自一个主题的消息时，会有一些充实发生，然后我们将消息发布到另一个主题。下面是一些事件
消费者-消费messageEnrichment -丰富了已消费的messageProducer -发布了其他主题的丰富信息。
我正在使用活页夹，一切都很好。最近，我们引入了幂等生成器并包含了transactionIdPrefix属性，并且我们观察到出站通道在主题中开始发送2条消息，因为它应该只发送一条消息。一条带有实际json的消息将另一条消息的值计算为‘b’\x00\x06&‘字符。下面是代码和配置。如果删除transactionIdPrefix，那么我可以看到只发送给出
浏览 3提问于2021-10-01得票数 1
我有一个@StreamListener方法，它将执行REST调用。当REST调用返回异常时，@StreamListener方法抛出RunTimeException并重试。@StreamListener方法抛出RuntimeException时，重试次数不限
Spring云流重试配置：
spring.cloud.stream.kafka.bindings.inputChannel.consumer.enableDlq=true
spring.cloud.stream.bindings.inputChannel.consumer.maxAttempts=3
spring.cloud.stream.
浏览 0提问于2018-08-27得票数 1
2回答
我已经用spring云流配置了一个基于spring引导的应用程序。我试图在一个KStream上工作，但是我不断地得到错误"java.lang.IllegalArgumentException:方法必须是声明性的“。有人能帮我理解如何配置这个吗？我查阅了StreamListener文档，但无法让它开始工作。
配置
spring.cloud.stream.kafka.binder.brokers=localhost
spring.cloud.stream.kafka.binder.defaultBrokerPort=9092
spring.cloud.stream.default.con
浏览 0提问于2019-02-07得票数 4
回答已采纳
2回答
春云流源-不拉扯
、、、
我正在尝试开发一个定制的源代码，以验证中的概念。
我成功地正确地部署了它，但是似乎bean没有被拉出来。
下面是父pom.xml的一部分
...
<properties>
<spring-cloud.version>Hoxton.SR8</spring-cloud.version>
...
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.sprin
浏览 4提问于2020-10-15得票数 0
我正在做一个POC来演示一些Spring Cloud Kafka功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库
implementation 'org.apache.kafka:kafka-streams'
implementation 'org.springframework.cloud:spring-cloud-stream'
implementation 'org.springframework.cloud:spring-cloud-stream-binder-ka
浏览 0提问于2021-01-30得票数 0
我们使用2.1.3版本的spring cloud stream kafka streams - <dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kafka-streams</artifactId>
<version>2.1.3.RELEASE</version>
</dependency&
浏览 12提问于2019-10-11得票数 1
最近发现了CVE-2022-22963弹簧云函数漏洞，这里的团队提供了一个简单的修补程序：。
我们通过以下依赖关系从spring-cloud-function-context:3.0.6获得spring-cloud-stream:3.0.4 ( spring.boot.version为2.2.6)：
spring-cloud-services-starter-circuit-breaker:2.2.6
弹簧云总线:2.2.6(包括amqp/kafka)
弹簧-云-启动-流-卡夫卡:3.0.4
春-云-启动-流-兔:3.0.4
我们没有直接使用RoutingFunctio
浏览 20提问于2022-04-12得票数 1
回答已采纳
我们有一个kafka过程，在这个过程中，我们使用来自一个主题的消息，然后会有一些充实发生，然后我们将消息发布到另一个主题。下面是一些事件
消费者-消费messageEnrichment -丰富了已消费的messageProducer -发布了其他主题的丰富信息。
我正在使用活页夹版本3.0.0-发行版，一切都很好。最近，我们引入了幂等生产者，并包括了transactionIdPrefix属性，我们发现我们开始出现性能问题。下面是统计数据。
在transactionIdPrefix系统之前花了大约20秒的时间来处理10k条消息，其中有30个并发用户。也就是说，每个second.After tra
浏览 5提问于2021-10-04得票数 0
1回答
我使用spring-cloud-sleuth-stream和spring-cloud-starter-stream-kafka发送span给kafka，连接时出现异常。spring cloud版本Edgware.SR1
spring
cloud:
stream:
kafka:
binder:
brokers: 192.168.1.177:9092
zkNodes: 192.168.1.177:2181
192.168.1.177是我的本地主机
我不明白为什么Updated
浏览 10提问于2018-02-05得票数 0
回答已采纳
使用spring-cloud-stream的kafka绑定器，如何配置并发消息消费者(在单个消费者jvm中)？如果我理解正确的话，使用kafka时使用并发消息消耗需要分区，但指出，要使用分区，您需要通过partitionKeyExpression或partitionKeyExtractorClass在生产者中指定分区选择。Kafka文档提到了循环分区。
s-c-s文档根本没有提到spring.cloud.stream.bindings.*.concurrency，尽管这在我上面描述的用例中似乎很重要。使用生产者配置
spring:
cloud:
stream:
bind
浏览 2提问于2016-03-08得票数 7
我已经在这个问题上挣扎了几天了。我想将Spring Cloud Data Flow Server for Cloud Foundry部署到我的组织的企业Pivotal Cloud Foundry实例。我的问题是强制所有数据流服务器web请求到TLS/HTTPS。下面是我尝试过的一个配置示例：
# manifest.yml
---
applications:
- name: gdp-dataflow-server
buildpack: java_buildpack_offline
host: dataflow-server
memory: 2G
disk_quota: 2G
浏览 3提问于2017-09-12得票数 0
给予：
cloud:
stream:
rabbit:
bindings:
inboundApolloLookupVehicleChannel:
destination: fed.apollo-vehicle-lookup-test
group: apollo-mngt-group
consumer:
missingQueuesFatal: true
prefetch: 25
autoBindDlq: true
浏览 2提问于2020-04-15得票数 0
在我的云流应用程序中，我使用了spring-cloud-starter-stream-processor-tasklaunchrequest-transform初学者应用程序作为任务处理器。
初学者是本地构建的，并安装在本地Maven存储库中。
用于启动本地Dataflow Server和DF，然后注册我的应用程序并创建-cum-部署流的命令如下：
在本地maven - mvn clean install中安装mvn clean install应用程序
在本地maven - mvn clean install中安装mvn clean install应用程序
在本地maven - m
浏览 4提问于2016-11-04得票数 0
回答已采纳
我在Spring项目中使用spring-cloud-aws-messaging。
我在AWS中手动创建了SQS队列。
它的使用方式如下：
@SqsListener("${sqs.name.incoming}")
public void listen(String message) {
...
}
效果很好。但是，当我在IDE中停止我的应用程序，或者当Spring测试结束时，它尝试停止队列。它无法阻止它并最终超时。它抛出此异常：
2019-10-29 15:40:07.949 WARN 10378 --- [ Thread-2] s.c.a.m.l.Simp
浏览 7提问于2019-10-29得票数 11
回答已采纳
我有一个主题，在我的流处理器中有多个分区，我只想从一个分区中流式传输它，并且可以弄清楚如何配置它
spring.cloud.stream.kafka.streams.bindings.input.consumer.application-id=s-processor
spring.cloud.stream.bindings.input.destination=uinput
spring.cloud.stream.bindings.input.group=r-processor
spring.cloud.stream.bindings.input.contentType=application/
浏览 1提问于2019-02-16得票数 0
1回答
我刚刚开始使用spring cloud dataflow项目。
我尝试使用上推荐的spring initialr创建一些自定义组件
我发现选定的几个组件很快就会发生冲突
例如，我生成了一个具有以下两个启动器的
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>
<
浏览 0提问于2016-08-09得票数 1
我正在尝试使用spring-cloud-stream，并创建official blog的示例项目。 实现与本文完全相同。 @SpringBootApplication
public class SimpleConsumerApplication {
@Bean
public java.util.function.Consumer<KStream<String, String>> process() {
return input ->
input.foreach((key, value) -> {
浏览 34提问于2021-04-12得票数 0
在我们的用例中，我们需要创建消息流应用程序并将其部署到我们的私有云创建环境中。流应用程序用于侦听RabbitMq队列，并触发流中定义的任务。
为了达到同样的目的，我们通过在Mac上本地运行cloud-dataflow-server-cloudfoundry来使用它。
以下是实现这一目标的一组命令：
设置Maven远程回购export MAVEN_REMOTE_REPOSITORIES_REPO1_URL=https://ftl.abc.com/NEXUS
安装云铸造目的地-
出口SPRING_CLOUD_DEPLOYER_CLOUDFOUNDRY_URL=出口SPRING_CLOUD_
浏览 1提问于2016-11-10得票数 0
回答已采纳
我最近切换到了Spring Cloud Stream的新测试绑定器。在我的项目中，我更新到了最新的Spring Cloud Stream版本3.1.3，删除了spring-cloud-stream-test-support依赖之后，MessageQueueMatcher.receivesPayloadThat匹配器就不再可用了。是否有新的匹配器或具有类似行为的替代匹配器？
浏览 11提问于2021-09-15得票数 0
回答已采纳
我需要实现一个类似ETL的函数，通过http调用将Mysql数据迁移到另一个系统。在这个过程中需要很高的实时性数据
我尝试将spring-cloud-starter-stream-source-jdbc和spring-cloud-starter-stream-processor-httpclient.结合起来。相反，我得到了spring-cloud-starter-stream-source-jdbc，没有主类错误。
jdbc --spring.datasource.driver-class-name=org.mariadb.jdbc.Driver --spring.datasource.us
浏览 49提问于2019-04-11得票数 1
我的任务是使用Spring Cloud Stream (使用Kafka绑定)。浏览Spring Cloud Stream的Quick Start，并从它使用的配置文件LogSinkConfiguration判断，这里的建议似乎是使用Spring Integration模式，例如@ServiceActivator(inputChannel = Sink.INPUT)来连接到输入通道。然而，我找到的所有教程都使用了来自Spring Cloud Stream库(vs Spring Integration)的一组不同的注释，即this演练中的@StreamListener(Processor.INP
浏览 24提问于2019-10-09得票数 1
回答已采纳
我正在尝试在Spring Cloud服务中启用hystrix流，在spring启动应用程序中使用Camden.SR1。我通过具有编译时依赖项来启用hystrix：
compile 'org.springframework.cloud:spring-cloud-starter-hystrix'
并在应用程序配置中添加@EnableHystrix。
/mappings执行器显示/hystrix.stream端点可用，但是当我在它上面执行GET时，请求无限期地挂起。我使用Brixton.SR6 (因此使用Spring Boot1.3)尝试了同样的方法，hystrix.stream端点
浏览 2提问于2016-10-27得票数 0
我使用的是spring cloud stream kafka。我已经为kafka设置了如下属性：
spring.cloud.stream.bindings.output.contentType=application/x-java-object;type=com.example.demo.KafkaApplication.Message
eureka.client.service-url.default-zone=http://172.16.165.26:8761/eureka/
spring.cloud.stream.kafka.binder.zkNodes=10.6.22.20
#spri
浏览 0提问于2017-06-21得票数 0
我正在尝试在spring cloud stream中实现延迟消息(不使用rabbitmq插件)，但它不起作用
我使用spring-boot实现了它，它工作得很好。下面是我在spring-boot中做的示例代码。
我正在尝试在spring-cloud-stream中做同样的事情，但是没有帮助。下面是属性。
输出通道-生产者
spring.cloud.stream.bindings.output.destination=temp-channel
spring.cloud.stream.bindings.output.group=temp-channel-group
输入渠道-消费者
spring
浏览 18提问于2019-08-14得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
