SpringXD Как процессор в потоке, чтобы получить данные из модуля источника Кафка

Question

Я следующий поток определен:

stream create aStream –definition “kafka –zkconnect=localhost:2181 --topic aTopic | aProcess" 

Мой вопрос заключается в том, что, как я должен закодировать Способ получени монатина, так что он может принимать данные (в String) из встроенного модуля источника kafka и распечатать данные? Большое спасибо.

Answer 1

Вам не нужно писать код. Все, что вам нужно сделать, это указать модель потокового потока в определении потока.

поток создать aStream -definition "kafka -zkconnect = localhost: 2181 --topic aTopic | log "--deploy

Будет записывать его в STDOUT вашего контейнера XD, или вы можете использовать приемник файлов для записи его в файл. Единственный раз, когда вам нужно написать собственный модуль, - это получить функциональность не предоставленные любым из источников, поглотителей или процессоров из коробки, найденные по адресу http://docs.spring.io/spring-xd/docs/current/reference/html/