我正在尝试为我设置的各种流创建一个聚合计数器。在SpringXD中，它看起来像这样：“tap：stream：MyCustomStream> aggregate-counter”。现有流上的聚合计数器
在Spring Cloud Dataflow到目前为止，我已经完成了“：MyKafkaTopic> aggregate-counter”，它似乎创建了一个Kafka使用者并读取有效负载以确定该主题事件的计数。我希望能够点击任何流，而不仅仅是Kafka来源，例如“MyApp1 | MyApp2” - 名称MyCustomStream。
提供的示例“流创建 - 定义”：主流.http - “名tap_at_http --deploy”本质上假定主流.http是Kafka主题（或RabbitMQ主题）。
以前有人做过这个吗？
你的榜样去，
流生成foo --definition “MyApp1 | MyApp2”
如果你不得不在生产者挖掘foo流，MyApp1水平，你的TAP流会喜欢以下内容。
流创建栏--definition“：foo.MyApp1> MyApp3”
你只是指向流中的制片人，你想点击来获得的同一副本数据。格式是：:<streamName>.<label/appName>。您也可以使用“标签”而不是应用程序名称。请查阅reference guide了解更多详情。
所提供的示例 “流创建--definition ”：mainstream.http>计数器“ --name tap_at_http --deploy” 基本上假定mainstream.http是卡夫卡主题（或话题的RabbitMQ）。
在这种情况下，mainstream是流的名字和你在http源应用程序，这相当于:mainstream.http TAP'ing。
这与Spring XD中的tap:stream:foo类似。默认情况下，Spring XD假设生产者只有在流中。不过，您必须在处理器上点击时指定它。
在SCDF中，我们特别要求它使其更具描述性，DSL也易于遵循。