2017-01-11 31 views
0

Kafkaストリームを使用して、永続性を維持するためにあるWebサービスから他のWebサービスに画像ファイルを送信しています。プロセス中にイメージをバイトの配列に変換し、Base64でエンコードされた文字列に変換し、他のファイルメタデータとともにメッセージとして送信します。画像ファイルのサイズが大きいため、Kafkaはダウンしています。Kafkaからファイルを送信する

ファイルメタデータとともにKafkaを介してこれらのイメージをストリーミングする方がいいですか?

答えて

2

compressionのデータをKafkaプロデューサーが使用したい場合があります。スプリングクラウドストリームカフカバインダーはプロパティを使用して圧縮タイプを指定することができ:spring.cloud.stream.kafka.bindings.<channelName>.producer.compressionType

このプロパティは、(デフォルトで)非圧縮のための圧縮とnoneの値としてsnappygzipを受け付けます。

+0

ありがとうGopi!また、カフカプロデューサーからのファイルを投稿し、消費者から受け取るためのサンプルコードもありますか? – rajcool111

+0

こんにちは、申し訳ありませんが、私は今のための例がありません。しかし、カフカプロデューサが圧縮タイプで設定されると、コンシューマは圧縮タイプセットに基づいて圧縮解除します。 –

関連する問題