カフカソース（Springクラウドデータフロー）

Question

私はSpring XDからSpring Cloud Data Flowに移行しています。私がモジュールリストを探しているとき、私はいくつかのソースがSpring Cloud Flowにリストされていないことに気付きました。その1つはKAFKAソースです。

私の質問は、春の雲のデータフローの標準ソースリストからKAFKAソースが削除された理由です。あなたが保つことができる - 私はモジュールのリストを探していたとき

Answer 1

は、私はソースのいくつかは、アプリケーションの

大半がに移植され、残りはインクリメンタルに優先順位を付けている春クラウドフローに記載されていないことに気づきましたbacklogの残りのサブセットのトラック。

私の質問は、春の雲のデータフローの標準ソースリストから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