问题标签 [spring-cloud-stream]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
spring - 如何在spring cloud stream和kafka中从同一主题发送和接收
我有一个spring-cloud-stream带有 kafka 绑定的应用程序。我想从同一个可执行文件（jar）中发送和接收来自同一个主题的消息。我的频道定义如下：-
public interface ChannelDefinition {
@Input("forum")
public SubscriableChannel readMessage();
@Output("forum")
public MessageChannel postMessage();
}
我@StreamListener用来接收消息。我收到各种意外错误。有时，我收到
- 没有为所有其他消息找到 unknown.message.channel 的调度程序
- 如果我将命令行 kafka 订阅者附加到上述论坛主题，它会收到所有其他消息。
- 我的应用程序接收所有其他消息，这是来自命令行订阅者的专有消息集。我已确保我的应用程序以特定的组名订阅。
是否有上述用例的工作示例？
java - Spring Cloud Stream Kafka binder 压缩
如何使用 Spring Cloud Stream Kafka Binder 为生产者启用压缩（例如 GZIP）？
spring-xd - Spring Cloud 数据流中的 Kafka 源码
我正在从 Spring XD 迁移到 Spring Cloud Data Flow。当我在寻找模块列表时，我意识到 Spring Cloud Flow 中没有列出一些源 - 其中之一是 KAFKA 源。
我的问题是为什么从春季云数据流中的标准源列表中删除了 KAFKA 源？
java - Spring Cloud Stream Kafka 记录太大
我有一个应用程序试图通过 Spring Cloud Stream 在 Kafka 上发送相当大的（> 4 mb）消息。我目前收到此错误：
org.apache.kafka.common.errors.RecordTooLargeException：此消息在序列化时为 4280852 字节，大于您使用 max.request.size 配置配置的最大请求大小
有没有办法为 Spring Cloud Stream 生产者设置“max.request.size”？
spring-integration - Spring Cloud Data Flow中如何配置Kafka绑定死信队列
在 Spring Cloud Dataflow 文档中，提到了“死信队列”，可用于消息处理中的异常。但是我没有在任何地方找到更多关于这个的信息。我正在尝试在我的处理管道中配置一个 Kafka 绑定的死信队列。
任何人都可以帮助我或指向文档以了解更多信息吗？
spring-aop - 将 LoggingAspect 与 Spring Cloud Data Flow Custom Sink 一起使用时出现异常
我正在尝试在 Spring Cloud Data Flow 中编写自定义接收器。一切正常。然后我介绍了 Logging Aspect for Logging，我开始遇到这个问题
通过调查，似乎有些 jar 类冲突，但无法找出确切的问题。
spring-xd - 在 Spring Cloud Data Flow 中使用来自 kafka 源的数据时出现异常
尝试将 kafka 主题作为源时，我遇到了 kafka 异常
这是我创建流的方式
当我运行它时，我在日志文件中遇到异常
我看到一些线程提到设置此属性 - 'spring.cloud.stream.bindings.input.consumer.headerMode=raw' 会有所帮助，但不知何故这不起作用。
spring-cloud - 使用spring cloud stream时如何使用turtle聚合集群中的hystrix指标
我们想更改我们的 hystrix/turbine 设置以使用 spring-cloud-stream（带有 Kafka 总线）。更改非常简单，我可以在仪表板中看到我所有的 hystrix 电路和指标……但是我的集群分组不再起作用了……
在较旧的设置中，我的 中将具有以下属性boostrap.yml：
我的涡轮机配置会是这样的：
我认为，由于我们现在使用的是 kafka 总线，因此不再使用 eureka，而且这还没有实际意义，但我现在不知道如何设置集群名称......我可以在 appname 前面加上一个集群命名并使用 clusterNameExpression 提取前缀，但也许我可以做一些更简单的事情......有什么想法吗？
编辑 1：我不能使用 clusterNameExpression ...它们在 spring-cloud-starter-turbine-stream 中不可用...
编辑 2：看起来 spring-cloud-starter-turbine-stream 使用 Turbine 2，而 spring-cloud-starter-turbine 使用 Turbine 1。 Turbine 2 在配置方面确实不同......
spring-cloud-stream - 更深入地自定义 Spring Cloud Stream
我已经开始使用 Spring Cloud Stream，其他团队成员就您可以自定义的深度提出了一些问题。具体来说：
- 详细配置访问交易所
- 交换与队列的分离
- 队列定制
- 根据可自定义的路由键将消息发布到交换器
- 基于路由键将队列绑定到交换器
我知道 spring cloud stream 旨在快速启动并运行，但是对于那些想要深入定制的人，是否有选择或者我们应该跳过它直接进入 spring 集成或 spring rabbit ？