spring-cloud-stream 相关问题

Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。

带有apache-kafka-binder的Spring-cloud-stream功能模型

这是这个问题的后遗症。我可以将“普通” Apache Kafka Binder与功能模型一起使用吗？到目前为止，我使用基于注释的配置将spring-cloud-stream-binder -...混合在一起。

apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

回答 1 投票 0

Spring cloud stream kafka绑定程序是否可以允许/拒绝重试特定例外？

是否可以在application.yml中添加属性，以在以下定义的策略中重试某些异常，包括/排除某些异常？我发誓我读过某处有财产...

spring-cloud-stream spring-retry

回答 1 投票 0

当无法重发异常时发送消息到DLQ

我仅通过使用属性来使用Spring Cloud Streams和默认的Spring Retry机制。我目前有一个应用程序，当MyCustomException ...

spring spring-cloud-stream spring-retry

回答 1 投票 0

春云卡夫卡流活页夹的健康状况为“未知”

我们正在使用2.1.3版本的春季云流kafka流- org.springframework.cloud spring-cloud -... ]

apache-kafka-streams spring-cloud-stream

回答 1 投票 0

Springboot云流kafka绑定程序，不记录整个有效负载（failedMessage = GenericMessage）

在重试后消费者失败的情况下，我看到整个有效负载都被记录下来了。 failedMessage = GenericMessage [有效载荷=是否有掩盖或隐藏它的简便方法？

spring-integration spring-kafka spring-cloud-stream

回答 1 投票 0

Spring Cloud Stream多种功能定义

是否可以使用具有多个单独功能/绑定的功能（spring.cloud.function）样式进行反应式SCS应用程序？我发现的所有示例始终只注册一个...

spring-cloud-stream reactive spring-cloud-function

回答 1 投票 0

Spring Cloud Data Flow无法上传包。信息库[本地]中的软件包[test-stream-comments：1.0.0]已存在

我已经在Spring云数据流中创建了一些流。我部署了它们，它们运行平稳。然后我取消了部署它们，当我尝试通过单击“部署流”重新部署流时，我...

spring-cloud spring-cloud-stream spring-cloud-dataflow

回答 1 投票 1

Spring Cloud Stream RabbitMQ-使用标头而不是路由键进行分区

我正在浏览文档，但找不到与此相关的任何内容，因此我在这里只是为了与您确认。我们想使用Spring Cloud Stream对Rabbit队列进行分区，但是希望...

rabbitmq partitioning spring-cloud-stream

回答 1 投票 0

为同一主题创建多个使用者，而不在kafka中创建重复的偏移量

我的问题是我只有一位制片人。产生两次到主题名称t1的消息“ hello1”，“ hello2”。我有两个消费者名称c1，c2。所以我想让c1使用者消息“ hello1”和c2使用者消息“ hello2” ...

spring-boot apache-kafka spring-cloud-stream

回答 1 投票 -1

如何在Spring Cloud Stream配置中为所有RabbitMQ使用者更改默认恢复间隔？

文档指出，RabbitMQ绑定器使用者的默认恢复间隔为5000毫秒。 RabbitMQ绑定器配置属性以spring.cloud.stream.rabbit.bindings。 ] >>>> 是 spring.cloud.stream.rabbit.default.consumer.recovery-interval=3000 （没有bindings.）。您拥有的是名为default的绑定的配置。

java spring rabbitmq spring-cloud spring-cloud-stream

回答 1 投票 0

向Spring Cloud Data Flow注册Python应用

我需要利用python代码库来做一些NLP和ML。但是，我也想使用Spring Cloud Data Flow来注册这些python脚本应用程序等。我正在使用kafka作为消息传递...

python spring-cloud-stream spring-cloud-dataflow

回答 1 投票 0

Spring Cloud Data Flow UI-运行时选项卡从不加载

我已经尝试了一些基本的教程来在Spring Cloud数据流中创建和部署流应用程序。每当我尝试部署应用程序时，spring cloud数据流就会挂起。甚至早于...

spring-cloud-stream spring-cloud-dataflow

回答 1 投票 0

Spring-cloud-stream MessageConversionException

我有一个@StreamListener，它接受一个@Payload字符串。为了测试此Listener类，我使用嵌入式Kafka编写了Junit类。我在运行测试类Error时遇到错误...