Spring Cloud Stream与@Publisher注释兼容性

文章/答案/技术大牛

发布

2回答

spring、spring-boot、spring-integration、spring-cloud、spring-cloud-stream

由于Spring Cloud Stream没有用于向流发送新消息的注释(@SendTo仅在声明了@StreamListener时有效)，因此我尝试使用Spring Integration注释来实现此目的，即@Publisher。因为@Publisher接受一个通道，并且Spring Cloud Stream的@EnableBinding注解可以使用@Output注解绑定输出通道，所以我尝试用以下方式

浏览 13提问于2019-01-12得票数 3

回答已采纳

2回答

春云流源-不拉扯

java、spring-kafka、spring-cloud-stream、spring-cloud-dataflow

<properties> ...</groupId> <version>${spring-clou

浏览 4提问于2020-10-15得票数 0

2回答

MessageDispatchingException: Dispatcher没有订阅服务器

spring-boot、apache-kafka、spring-cloud-stream、spring-cloud-stream-binder-kafka

接口 MessageChannel publisher(); public void listen(MyEvent message) {}spring.cloud.stream.bindings.publisher.destination=my-kafka-topic

浏览 1提问于2020-01-03得票数 2

回答已采纳

1回答

如何在RabbitMQ中动态创建队列的“N”号

spring-boot、rabbitmq、spring-cloud-stream、spring-rabbit

我试图使用StreamBridge SpringBoot和RabbitMQ作为代理来创建动态的n个队列--我以前用这种方法创建了队列spring.cloud.stream.bindings.sender-in-0.destination=sampleQueuespring.cloud.<em

浏览 5提问于2022-11-10得票数 0

1回答

当使用连接前缀属性时，兔子绑定程序会导致循环依赖错误。

spring-cloud-stream、spring-rabbit

=hostspring.cloud.stream.binders.simple-rabbit.environment.spring.rabbitmq.password=pswd spring.cloud.stream.binder

浏览 0提问于2020-09-17得票数 0

2回答

春云流是否受CVE-2022-22963 (春季云功能)的影响？

spring-boot、spring-cloud-stream、spring-cloud-function、spring-cloud-circuitbreaker

我们通过以下依赖关系从spring-cloud-function-context:3.0.6获得spring-cloud-stream:3.0.4 ( spring.boot.version为2.2.6)：春-云-启动-流-兔:3.

浏览 20提问于2022-04-12得票数 1

回答已采纳

1回答

使用Spring的现有队列

spring-boot、rabbitmq、amqp、spring-amqp、spring-cloud-stream

下面是从Wireshark发来的信息的截图： spring.cloud.stream.bindings.input.group=********************.instana.testspring.cloud.stream.rabbit.bindings.input.consumer.bind

浏览 0提问于2018-10-16得票数 1

回答已采纳

1回答

春云流消费者没有阅读卡夫卡主题的信息

spring-boot、apache-kafka、spring-cloud-stream、spring-cloud-stream-binder-kafka

Publisher是用不同的微服务编写的。</artifactId><dependency><artifactId>spring-cloud-stream</artifactId><dependency&g

浏览 4提问于2021-11-29得票数 2

1回答

Spring云流rabbitmq在使用者中指定主题

spring-cloud-stream

我的制作人有下面的application.propertiesspring.cloud.stream.bindings.output.producer.partition-key-extractor-class=publisher.partitionstrategy.PartitionKeyExtractorImpl spring</e

浏览 1提问于2016-09-13得票数 0

回答已采纳

1回答

Spring Cloud stream与kafka的兼容矩阵

apache-kafka、spring-cloud、spring-kafka、spring-cloud-stream

它使用的是spring cloud stream和kafka绑定器版本2.0.2。在内部，它似乎在使用kafka-client 1.0.2此外，spring-kafka页面告诉您参考kafka以获得客户端-代理兼容性但是我发现了这个页面，它显示，无论Kafka客户端是什么，spring cloud只与Kafka broker版本1.1.x、1.0.x、0.11.0.

浏览 12提问于2021-02-19得票数 1

回答已采纳

1回答

bean类的注释指定的bean名称‘errorPageFilter

spring-cloud-stream

使用spring cloud stream时，会遇到以下问题：我的spring cloud蒸汽依赖关系的判断是

浏览 0提问于2016-11-10得票数 2

2回答

如何处理RabbitMQ中未知/无效的绑定路由键值？

java、spring-boot、rabbitmq、amqp、spring-cloud-stream

下面是我的配置(我正在使用Stream)：spring.cloud.stream.bindings.output.producer.routingKeyExpression: payload.type spring.cloud.stream.bindings.input-type1.desti

浏览 1提问于2020-12-03得票数 0

回答已采纳

1回答

Spring messaging AMQP需要接受所需群组关于消息传递的回复

java、spring、spring-integration、spring-rabbit、spring-messaging

我有一个关于spring-messaging (spring集成+ amqp)与RabbitMQ的问题。我有一个基于微服务架构的应用程序。一条服务发布消息，方式如下：@Publisher(channel = "messages") rabbitmq: port: 5672 stream</em

浏览 0提问于2017-04-09得票数 1

2回答

Dispatcher没有订阅频道“员工管理-1.1.kafka log-publisher”的用户。

spring、spring-boot、apache-kafka、spring-cloud-stream

</groupId> <version</groupId> <&

浏览 3提问于2021-11-28得票数 0

1回答

Spring Cloud Bus事件( RemoteApplicationEvent )未发布到Kafka

apache-kafka、spring-cloud-stream、spring-cloud-bus

我正在使用spring cloud bus将事件发布到kafka，以便其他实例可以监听相同的事件。事件正在被触发，但未发布到kafka。我正在使用spring cloud bus和spring cloud stream。版本: Spring Boot : 2.0，Spring cloud Bus : 2.0.0，Spring Cloud Stream : 2.0.

浏览 3提问于2019-07-24得票数 1

1回答

例外情况: org.springframework.messaging.MessageDeliveryException:调度程序没有订阅通道的用户

java、spring-cloud、spring-cloud-stream、spring-cloud-function

首先，我在项目Function<String, String>中添加了相应的spring.cloud.stream.bindings和spring.cloud.stream.function.definition然后，我将Supplier<Flux<String>>添加到具有相应spring.cloud.stream.bindings的同一个项目中，并将spring.clo

浏览 2提问于2020-01-15得票数 2

回答已采纳

3回答

异常HandlerMethodArgumentResolversHolder

spring、spring-boot、spring-data、spring-integration、spring-cloud

org.springframework.cloud.stream.config.BindingServiceConfiguration.bindingService <dependency> <groupId>io.pivotal.spring</e

浏览 8提问于2018-12-28得票数 6

2回答

Spring中没有@EnableBinding注释的Kafka绑定

spring、binding、apache-kafka、spring-cloud-stream

我正在使用spring cloud连接到我的Kafka经纪人。它工作得很好。现在我想通过代码而不是注释来创建我的绑定。有没有一种方便的方法呢？

浏览 1提问于2017-07-16得票数 0

1回答

是否可以在Spring* Cloud Stream Kafka Streams 3.0 Binder风格的API方法上使用@KafkaStreamsStateStore注释？*

apache-kafka-streams、spring-cloud-stream

是否可以在Spring Cloud Stream Kafka Streams 3.0 Binder风格的API方法上使用@KafkaStreamsStateStore注释？: ; nested exception is org.springframework.kafka.KafkaException: Could not start stream: ; nested exception: ; nested exception is org.springframework.kafka.KafkaExcept

浏览 33提问于2020-06-19得票数 1

回答已采纳

1回答

将Spring集成路由器与Spring* Cloud *Stream配合使用

spring-boot、spring-integration、spring-cloud-stream、spring-cloud-stream-binder-kafka

我一直在尝试使用Spring Integration的@Router和带有Kafka绑定的Spring Cloud Stream。我的理解是，当您从带有@Router注释的方法返回频道名称的List时，它们应该被生成到目标Kafka主题。但我没有看到正在产生的消息。Spring Integration的@Router可以与Spring Cloud Stream一起工作吗？如果不是，有什么替代方案，我如何以编程方式路由

浏览 16提问于2020-04-06得票数 0

回答已采纳

点击加载更多