spring-cloud-stream相关内容
1) 我已经使用 cf push -p abcdef.jar sinkapp 在 PCF 上注册了一个接收器应用程序.一切顺利 2) 现在我的 SCDF 服务器也在 PCF 上 如何使用位于同一 PCF、同一组织、同一空间上的数据流在 SCDF 服务器上注册 sinkapp.因为我不知道我应该参考什么来注册它?我正在寻找可以从数据流 shell 提供给 SCDF 的命令. 谢谢.
..
我正在开发 Spring Cloud 数据流流应用程序.我能够使用在 Cloud Foundry 中运行的船长在本地运行 Spring Cloud 数据流服务器，配置如下.现在我正在尝试与在 kubernetes 集群中运行的船长运行相同的程序.我如何指定相同的? manifest.yml ---应用:- 名称:poc-scdf-server内存:1G实例:1路径:../target
..
我正在尝试使用 Spring 云数据流流的 poc，并使应用程序 iis 在 Pivotal Cloud Foundry 中运行.在 kubernetes 中尝试相同并且 spring 数据流服务器仪表板未加载.调试该问题并发现根本原因是当仪表板加载时，它试图点击 Skipper 休息端点/api 并返回带有以下网址的响应船长中的其他端点，但返回 url 都在 http 中.如何强制船长返回 ht
..
我要找的拓扑是 到目前为止，我还没有看到在 Cloud Stream 中定义每条消息的主题的方法.我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每条消息的主题? source.output().send(MessageBuilder.withPayload(myMessage).build()); 不提供任何方法来设置交换主题以路由到适当的消费者. 或
..
我正在尝试使用 spring cloud stream 和新功能支持配置，但我在理解如何实现与注释配置相同的结果时遇到问题. 每次创建用户时，我都需要向代理发送消息.使用基于注释的配置，我可以像这样完成它: public UserProducer {@自动连线私人最终来源；@自动连线私有最终 UserRepository 存储库；public void saveUser(用户用户){存储
..
基于 Spring Cloud Data Flow (SCDF) 的文档，仅以“已部署"为前缀的属性.或“应用程序".在将应用程序(无论是源、处理器还是接收器)部署为流的一部分时会考虑. 但是，我注意到除了前缀之外，所有属性都必须以“字符串"的形式提供，无论它们的原始类型是什么；否则，它们会被 SCDF 按照这行代码简单地丢弃: propertiesToUse = DeploymentP
..
到目前为止我已经实现了: 带有“本机"存储库的 Spring Cloud 配置服务器. spring.profiles.active:原生 spring.cloud.config.server.native.searchLocations: file:/path/to/config-repo Config Server 正在通过 RabbitMQ 向 Config Clie
..
你能告诉我如何停止发送到我的第三个 kafka 主题，当控件到达 catch 块时，当前消息被发送到错误主题以及在正常情况下应该发送到的主题处理.代码片段如下: @Component公共类 Abc {私有最终 StreamBridge streamBridge；公共 Abc (StreamBridge streamBridge)this.streamBridge = 流桥；@豆公共函数
..
我在 spring-boot(consumer) 应用程序中使用 spring-cloud-stream-kafka.应用程序的运行状况不准确，即使应用程序无法连接到 Kafka(Kafka 代理已关闭)也“UP".我已阅读有关 kafka 健康检查的文章.看起来 kafka 健康检查在 spring 执行器健康检查中被禁用. 因此，我设法编写了以下代码来为我的应用启用 kafka 健康检查
..
尝试使用以下 示例来自 Spring文档 @Bean公共 MessageConverter userMessageConverter() 抛出 IOException {AvroSchemaMessageConverter avroSchemaMessageConverter {返回新的 AvroSchemaMessageConverter(MimeType.valueOf("avro/byte
..
我正在编写一个处理事件消息的应用程序(发布到主题file-upload-completed).我有多个端点应该使用这些消息(metadata-reader 和 quota-checker)，出于实用的原因，我想将这些端点一起部署在一个聚合包中. 使用 Spring Cloud Stream，我可以使用 spring.cloud.stream.bindings.file-upload-comp
..
文档非常直接，它建议公开 KafkaBindingRebalanceListener 类型的 Bean，并且将在内部调用 onPartitiosnAssigned 方法.我正在尝试做同样的事情，并且在 spring 框架创建其 KafkaMessageChannelBinder Bean 时，ObjectProvider.getIfUnique() 总是返回 null，因为它无法找到所需的 bea
..
嗨，我正在为 Kafka 试用最新的 Spring 云流框架.但是，对于 String 和 Double 其工作正常，但是当我尝试发送 Java POJO 类时，它会引发以下异常. 我尝试了各种用于序列化和反序列化的配置，但似乎没有任何效果.我能够以 json 格式从供应商处生成消息，但由于错误，消费者无法处理它. 对此问题的任何建议将不胜感激.谢谢 org.springframew
..
我正在使用 spring-cloud-starter-stream-kafka 创建一个 Kafka 消费者绑定并且我已经配置了 spring.cloud.stream.bindings.input.consumer.autoStartup 到 false (https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.2
..
我有一个主题和与之相关的 DLQ.我正在使用@StreamListener 作为主题.我想使用控制器端点按需读取/处理来自 DLQ 的消息. 是否可以使用 Spring Cloud Stream Kafka 来做到这一点. 我们没有在生产中使用执行器.所以不能使用/bindings 端点. 解决方案 您不需要通过 web 启用执行器，但需要将执行器启动器添加到类路径；那么你可以
..
我使用 spring-cloud-config 和 spring-cloud-bus 创建了一个简单的项目.出于某种原因，配置客户端两次调用配置服务器.第一次发生在创建引导程序的上下文时(预期行为是什么)，但第二次在创建绑定程序的上下文时调用. 这是在课堂上完成的: DefaultBinderFactory#getBinderInstance: //如果环境没有自定义并且有一个主上下
..
我是 Kafka Streams 和 Spring Cloud Stream 的新手，但在将集成相关代码移动到属性文件方面阅读了有关它的好消息，因此开发人员可以主要关注事物的业务逻辑方面. 这里有我的简单应用程序类. package com.some.events.consumer导入 com.some.events.SomeEvent导入 org.apache.kafka.streams
..
我正在尝试使用 Spring 云流将数据从 kafka 发送到 Rsocket，然后在 React 上表示数据 这是我的配置. @Configuration公共类 RsocketConsumerConfiguration {@豆公共接收器.许多发件人(){返回 Sinks.many().multicast().directBestEffort();}} @控制器公共类 ServerCon
..
我正在从头开始学习 Spring Cloud Streams. 我尝试创建这样的 Source 应用程序: import org.springframework.cloud.stream.messaging.Source;//等@RestController@SpringBootApplication@CrossOrigin@EnableBinding(Source.class)公共类 S
..
我的系统上有一个更改请求，它当前侦听多个频道并向多个频道发送消息，但现在目标名称将在数据库中并随时更改.我很难相信我是第一个遇到这种情况的人，但我看到的信息有限. 我只找到了这两个... 动态接收器目的地:https://github.com/spring-cloud-stream-app-starters/router/tree/master/spring-cloud-starter-s
..
