基本上我正在将 mongo 接收器(消费者)应用程序从基于注释的方法切换到使用消费者 bean 的功能模型。
新代码
@豆
公共消费者
}
当我将它们部署在 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