2016-10-20 4 views
0

コンフルエントなカフカレストシリアライザを変更することはできますか?コンフルエントなavroシリアライザを私のカスタマイズしたシリアライザに交換したいのですが、プロデューサプール(https://github.com/confluentinc/kafka-rest/blob/2.x/src/main/java/io/confluent/kafkarest/ProducerPool.java)をチェックしました。コンフルエントなカフカレストシリアライザの設定方法は?

buildAvroProducerをビルドするときに、コンフルエントなlibであるKafkaAvroSerializerを要求します。したがって、コードを変更しなくてもカスタマイズすることはできないようです(クラスパスまたはsthのjarファイルを単純に入れ替えるなど) この要件が公正であるかどうか、そしてロードマップ上にあるかどうかは不明です。

答えて

1

申し訳ありませんが、これは現在できません。一連のシリアライザは、一連のコンテンツタイプにマップするためにハードコードされています。別のシリアライザをサポートするには、コードを変更する必要があります。

+0

ここで質問をお手伝いできますか? http://stackoverflow.com/questions/40644085/confluent-schema-registry-2-0-1-version-with-ssl-configuration – edi

関連する問題