尝试将函数运行器部署到scdf k8s中。
http --server.port=9001 | f-run: function-runner --function.className=com.example.functions.CharCounter --class-name=com.example.functions.CharCounter --location="maven://io.spring.sample:function-sample:jar:1.0.2" | log
我已经使用function-runner-kafka 1.1.0.M1
创建了一个docker镜像。
总是得到:
***************************
APPLICATION FAILED TO START
***************************
Description:
Binding to target org.springframework.cloud.stream.app.function.app.FunctionProperties@264f218 failed:
Property: function.className
Value: null
Reason: may not be empty
Action:
Update your application's configuration
在流定义中,如何将maven
uri设置为function-jar
我想使用jar代码将函数运行器运行到scdf k8s中。
发布于 2019-04-01 13:12:02
function-runner
模型被弃用,取而代之的是Spring Cloud Stream中提供的原生Spring Cloud函数集成。
您可以简单地使用function @Bean
构建一个Spring Cloud Stream应用程序,并将它们作为链的一部分,或者在运行时解析为一个单独的函数。
有关更多详细信息,请参阅ref. guide。
一旦你有了一个具有多个功能@Bean
的应用程序,你也有能力将它们与其他App Starters组合在一起,并在SCDF DSL中使用它。
有关更多背景信息,请参阅此blog on this subject。
https://stackoverflow.com/questions/55455066
复制相似问题