当前位置: 首页 > 知识库问答 >
问题:

自定义SCDF初学者应用程序写入“输出”主题

雍飞雨
2023-03-14

我创建了一个流,类似于:stream create stream-name--definition“app-name log”

首先,它按照约定stream-name.app-name创建了一个主题,我希望它能向我显示那里的消息,但它实际上写入了“output”主题,这很奇怪。我没有提供任何额外的配置。我在SCDF最新版本和1.2.0.版本中尝试了它,结果相同。

共有1个答案

景翰音
2023-03-14

由于创建了主题stream-name.app-name,SCDF将正确设置源应用程序的出站目标名称。注意,SCDF只为应用程序设置spring.cloud.stream.bindings.output.destination属性。这里,出站通道假定为output

我想您的自定义应用程序中的出站消息通道有一个不同的绑定目标名称。由于SCDF不为该应用程序设置目标,因此该应用程序默认将output作为目标。

检查自定义应用程序中的出站目标名称。您需要将属性spring.cloud.stream.bindings. .Destination 设置为应用程序的部署属性。

dataflow:>stream deploy stream-name --properties "app.source-app-name.spring.cloud.stream.bindings.customOutboundTargetName.destination=yourTopic,app.sink-app-name.spring.cloud.stream.bindings.customInboudTargetName.destination=yourTopic"
 类似资料:
  • 我用kafka绑定器创建了一个简单的spring cloud流“源”和“汇”应用程序,并在SCDF(spring cloud Data Flow)中注册了JAR。 在SCDF(source-app sink-app)中创建了steam,并成功地部署了该流。 我的源应用程序很简单,代码如下: 在类级别上使用了@EnableBinding(Source.class)、@RestController。

  • 我在部署Grails应用程序时遇到了问题。一切都可以在本地测试环境中工作。 错误 [localhost-startStop-1]错误context.grailscontextloader-初始化应用程序时出错:创建名为“Transaction ManagerPostProcessor”的bean时出错:bean初始化失败;嵌套异常为org.springframework.beans.factory

  • 问题内容: 由于某些原因,我的代码将不接受最后一行“您想订购的商品:”的输入 谁能告诉我我的错误在这里吗?它正在正确地编译一切。我只是一个初学者,所以请简单地告诉我。 问题答案: 您需要在调用行的后面立即调用 ,原因是仅要求下一个整数不会占用输入中的整个行,因此您需要通过调用来跳至输入中的下一个新行字符 每次您需要在调用不消耗整行的方法后获取新行时,都必须执行此操作。考虑改用对象! 如果无法将输入

  • 我有以下表格: id与具有一对一映射的成员_id相关。 我写了两个模型作为例子 登录模式: Memeber模型: 为了简单起见,我放弃了一些getter和setter。不管怎样,你能告诉我哪里出了问题吗?在更改注释值时,我会遇到诸如映射未找到、持久类未知等错误。 错误 org.springframework.web.util.NestedServletExc0019:请求处理失败;嵌套异常是org

  • 本教程的主要内容是介绍如何使用 jMonkeyEngine 进行游戏开发,旨在帮助初学者快速理解 jMonkeyEngine 中的核心概念。由于作者本人水品有限,文中难以避免出现谬误,如您在阅读过程中发现有不对的地方,请告知本人,我会尽快修正。 jME3 官方网站: 官网: http://jmonkeyengine.org/ 论坛: https://hub.jmonkeyengine.org Gi