Comment configurer le sérialiseur de repos kafka confluent?

Question

Est-il possible de changer le sérialiseur kafka-repos confluent? Je veux permuter le sérialiseur avro confluent à mon sérialiseur personnalisé, mais j'ai vérifié dans le pool de producteur (https://github.com/confluentinc/kafka-rest/blob/2.x/src/main/java/io/confluent/kafkarest/ProducerPool.java).

Lors de la construction de buildAvroProducer, il demande KafkaAvroSerializer, qui est une librairie confluente. Il ne semble donc pas possible de le personnaliser sans changement de code (comme simplement échanger un pot dans classpath ou sth) Vous ne savez pas si cette exigence est juste ou non, et vous demandez s'il est sur la feuille de route ou pas.

Answer 1

Vous avez raison, ce n'est pas possible actuellement. L'ensemble de sérialiseurs est codé en dur pour correspondre à un ensemble de types de contenu. Vous devez apporter des modifications au code pour prendre en charge les sérialiseurs alternatifs.