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