2016-07-24 4 views
2

Я перемещаюсь из Spring XD в Spring Cloud Data Flow. Когда я ищу список модулей, я понял, что некоторые источники не указаны в Spring Cloud Flow. Один из них - источник KAFKA.Kafka Источник в Spring Cloud Data Flow

Мой вопрос: почему источник KAFKA удаляется из списка стандартных источников в потоке данных весенних облаков?

ответ

6

Когда я ищу список модулей я понял, что некоторые из источников не перечислены в Spring Cloud Flow

Большинство приложений перенесенных, а остальные будут постепенно приоритеты - вы можете сохранить отслеживать оставшееся подмножество в backlog.

Мой вопрос: почему источник KAFKA удаляется из списка стандартных источников в потоке данных весеннего облака?

Kafka не удаляется, и, на самом деле, мы высоко ценим Kafka в контексте потоковых прецедентов настолько, чтобы его непосредственно запекли в DSL. Подробнее here.

Например,

(я), если вы, чтобы потреблять от темы Кафки (в качестве источника), ваше определение потока будет:

stream create --definition ":someAwesomeTopic > log" --name subscribe_to_broker --deploy

(б) если вы, чтобы написать на тему Кафки (как раковина), ваше определение потока будет:

stream create --definition "http --server.port=9001 > :someAwesomeTopic" --name publish_to_broker --deploy

(где * someAwesomeTopic * является названный пункт назначения, название темы)

+0

любой рабочий пример того, как сделать это ?, я написал очень простое приложение консоли, которая использует производитель Кафка, чтобы отправить строку " testme "и подключить поток для песка к файлу, и он не пытается преобразовать сообщение: oscsbkKafkaMessageChannelBinder: Не удалось преобразовать сообщение: 746573746D65. Это число представляет собой ascii-представление сообщения "testme" – ka2

Смежные вопросы