onConfiguration$FunctionBindingRegistrar :您定义了不存在的函数定义:mongoSink

问题描述 投票:0回答:0

基本上我正在将 mongo 接收器(消费者)应用程序从基于注释的方法切换到使用消费者 bean 的功能模型。

新代码 @豆 公共消费者>输入(MongoDbStoringMessageHandler mongoDbSinkMessageHandler){ 返回 mongoDbSinkMessageHandler::handleMessage;}

旧代码: oldcode

} 当我将它们部署在 scdf 中时出现此错误
1."onConfiguration$FunctionBindingRegistrar : 你定义了不存在的函数定义:输入 2.onConfiguration$FunctionBindingRegistrar : 函数定义“输入”无效。引用的函数 bean 或其组件之一不存在

即使在添加此属性之后:app.custom-mongo.spring.cloud.function.definition=input

为什么我会收到这些错误并且 mongo sink app 没有连接到定义的队列

我已经添加了功能模型的弹簧定义属性并尝试仍然得到相同的错误

期望: 1.为什么获取函数不存在错误 2.为什么myqueue无法连接这个mongo sink app

functional-programming spring-cloud spring-cloud-stream spring-cloud-dataflow
© www.soinside.com 2019 - 2024. All rights reserved.