私はSpring XDからSpring Cloud Data Flowに移行しています。私がモジュールリストを探しているとき、私はいくつかのソースがSpring Cloud Flowにリストされていないことに気付きました。その1つはKAFKAソースです。カフカソース(Springクラウドデータフロー)
私の質問は、春の雲のデータフローの標準ソースリストからKAFKAソースが削除された理由です。あなたが保つことができる - 私はモジュールのリストを探していたとき
私はSpring XDからSpring Cloud Data Flowに移行しています。私がモジュールリストを探しているとき、私はいくつかのソースがSpring Cloud Flowにリストされていないことに気付きました。その1つはKAFKAソースです。カフカソース(Springクラウドデータフロー)
私の質問は、春の雲のデータフローの標準ソースリストからKAFKAソースが削除された理由です。あなたが保つことができる - 私はモジュールのリストを探していたとき
は、私はソースのいくつかは、アプリケーションの
大半がに移植され、残りはインクリメンタルに優先順位を付けている春クラウドフローに記載されていないことに気づきました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
これを行う方法のいずれかの作業例(* someAwesomeTopic *という名前の宛先、トピック名がある)?私は「文字列を送信するためにカフカのプロデューサーを使用して、非常に単純なコンソールアプリケーションを書きましたtestme "を作成し、ストリームをストリームに接続してファイルに接続し、メッセージの変換に失敗しました。oscsbkKafkaMessageChannelBinder:メッセージを変換できませんでした:746573746D65。この番号は、メッセージ "testme"のASCII表現です – ka2