我正在嘗試爲我設置的各種流創建一個聚合計數器。在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也易於遵循。