我创建了一个流,类似于:stream create stream-name--definition“app-name log”
。
首先,它按照约定stream-name.app-name
创建了一个主题,我希望它能向我显示那里的消息,但它实际上写入了“output”主题,这很奇怪。我没有提供任何额外的配置。我在SCDF最新版本和1.2.0.版本中尝试了它,结果相同。
由于创建了主题stream-name.app-name
,SCDF将正确设置源应用程序的出站目标名称。注意,SCDF只为应用程序设置spring.cloud.stream.bindings.output.destination
属性。这里,出站通道假定为output
。
我想您的自定义应用程序中的出站
消息通道有一个不同的绑定目标名称。由于SCDF不为该应用程序设置目标,因此该应用程序默认将output
作为目标。
检查自定义应用程序中的出站
目标名称。您需要将属性spring.cloud.stream.bindings.
设置为应用程序的部署属性。
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