kafkaプロデューサで使用するシリアル化を決定する方法は？

Question

kafkaのドキュメントを見ているうちに、私はkafkaプロデューサで多くのタイプのシリアル化を見つけましたが、どのユースケースでもシリアル化を決定する方法については混乱していますか？

Answer 1

あなたがシリアライゼーションの役割を知っていれば助かるかもしれないと思うので、カフカの仕組みはバイト配列（byte []）の観点からメッセージを見ることです。 Kafkaはあなたのメッセージを開いて、そのintかdoubleかstringかを判断するのではなく、送信バイト[]を仮定します。

しかし、生産者と消費者のための開発を容易にするために、Kafkaはシリアライザとデシリアライザインタフェースを定義しており、ペアで動作します。 Integerをメッセージとして使用して、byte []に​​変換し、消費者のkafkaに渡すIntegerSerializerを使用していることがわかっている場合は、IntegerSerializerを使用してメッセージがシリアル化されているので、IntegerDeserializerを使用します。あなたはカスタムJavaオブジェクトを持っている場合と同じ方法で、Javaオブジェクトをプロデューサのbyte []に​​変換し、対応するDeserializerをバイト[]をjavaオブジェクトに変換する方法（デフォルトjavaまたはKyroシリアライザ）を見つけなければなりません。

希望があれば