如何在春季云数据流中使用自定义处理器的命名目的地



这些天我在学习SCDF。。。我对指定的目的地有一些疑问。我创建了一个类似":测试主题>log";。我可以看到日志接收器消耗来自主题"的数据;测试主题";。但是,如果我在SCDF中添加一个自定义处理器,那么我会创建一个这样的流:

:测试主题源>etl数据转换>:测试主题接收器

我认为";etl数据变换";处理器将消耗来自主题"的数据;测试主题源";(Kafka(和产品数据到";测试主题汇";,但是日志是";已订阅主题:stringOperation-in-0";以及";使用kafka主题进行出站:stringOperation-out-0";("字符串操作"是我的自定义功能(

为什么SCDF不使用主题";测试主题源";以及";测试主题下沉"?如何解决?


我知道我可以使用这样的属性:spring.cloud.stream.function.bindings.stringOperation-in-0=inspring.cloud.stream.bindings.in.destination=测试主题源但如果我想输出到两个主题?

谢谢!

看起来您的自定义处理器应用程序使用inboundoutbound名称作为inout。SCDF期望这些名称分别为inputoutput。这就是您看到基于名称inout的显式绑定名称的原因。请将名称更改为inputoutput,我认为这应该可以解决这个问题。

Thx!那是我的错误。我将"@EnableBinding(Processor.class("添加到我的自定义处理器中,然后修复它。

最新更新