春季雲數據流中的Kafka源碼

我正在從Spring XD遷移到Spring雲數據流。當我在查找模塊列表時，我意識到一些源未在Spring Cloud Flow中列出 - 其中一個來源是KAFKA。春季雲數據流中的Kafka源碼

我的問題是爲什麼KAFKA源從春季雲數據流中的標準源列表中刪除？

來源

2016-07-24 Viren Balaut

當我尋找模塊列表，我意識到有些來源不春雲上市流通

大多數應用都移植過來，剩下的都是增量優先級 - 你可以保持追蹤backlog中剩餘的子集。

我的問題是爲什麼KAFKA源在春季雲數據流中從標準源列表中刪除？

卡夫卡沒有被刪除，事實上，我們在流媒體使用案例的背景下非常重視卡夫卡，因此它直接被燒入DSL。更多詳情here。

例如，

（i）如你從卡夫卡主題（作爲源）消耗，你流的定義是：

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

（II）如果您要寫卡夫卡主題（作爲接收器），則您的數據流定義將爲：

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

（其中* someAwesomeTopic *是指定目的地，主題名稱）

來源

2016-07-24 14:21:16

如何做到這一點的任何工作示例？我寫了一個使用卡夫卡生產者發送字符串「一個很簡單的控制檯應用程序testme「並將流連接到一個文件，並且它試圖轉換郵件失敗：oscsbkKafkaMessageChannelBinder：無法轉換郵件：746573746D65。這個數字是消息「testme」的ascii表示 – ka2

春季雲數據流中的Kafka源碼

回答

相關問題