0

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

buildAvroProducer をビルドするときに、コンフルエント ライブラリである KafkaAvroSerializer を要求します。そのため、コードを変更せずにカスタマイズすることはできないようです (クラスパスまたは sth で単に jar を交換するなど)。

4

1 に答える 1

1

その通りです。これは現在不可能です。一連のシリアライザーは、一連のコンテンツ タイプにマップするようにハード コードされています。代替のシリアライザーをサポートするには、コードを変更する必要があります。

于 2016-10-23T19:41:59.427 に答える