기존 스트림의 집계 카운터

Question

설정 한 다양한 스트림에 대한 집계 카운터를 만들려고합니다. SpringXD에서는 다음과 같이 보입니다 : "tap : stream : MyCustomStream> aggregate-counter".

Spring Cloud Dataflow에서는 지금까지 "MyKafkaTopic> aggregate-counter"를 수행했는데, 이는 Kafka 소비자를 생성하고 페이로드를 읽음으로써 주제에 대한 이벤트의 수를 결정합니다. 카프카 소스뿐만 아니라 모든 스트림을 탭하고 싶습니다. "MyApp1 | MyApp2"--name MyCustomStream.

제공된 예제 "stream create --definition": mainstream.http> counter "--name tap_at_http --deploy"는 본질적으로 mainstream.http가 Kafka 주제 (또는 RabbitMQ 주제)라고 가정합니다.

누구나 이전에이 작업을 수행 했습니까?

Answer 1

스트림 foo는 --definition 만들고, 귀하의 예제로가는 |, 당신은 생산자에서 MyApp1 수준을 foo 스트림을 활용할 수있을 것입니다 경우 "MyApp1 MyApp2"

당신의 TAP 스트림은 다음과 같습니다. 스트림 바 --definition을 만들

"foo.MyApp1> MyApp3"당신은 당신이 동일한의 사본을 얻을 TAP 할 위치 스트림의 제작자 가리키고

데이터. 형식은 :<streamName>.<label/appName>입니다. 앱 이름 대신 "라벨"을 사용할 수도 있습니다. 자세한 내용은 reference guide을 검토하십시오.

제공된 예 "--definition 생성 스트림"mainstream.http> 카운터 "--name tap_at_http --deploy"본질적 가정 mainstream.http는 카프카 주제 (또는 주제 RabbitMQ). 이 경우

, mainstream 스트림 이름이고 당신은 :mainstream.http 동일합니다 http 소스 응용 프로그램에서 TAP'ing 있습니다.

이것은 스프링 XD의 tap:stream:foo과 유사합니다. 기본적으로 Spring XD는 스트림에만있는 경우 제작자로 간주합니다. 하지만 프로세서를 사용할 때 지정해야합니다.

SCDF에서 우리는 더 구체적으로 설명하고 DSL을 쉽게 따르도록 요구합니다.