如何配置 confluent kafka rest 序列化器？

Question

是否可以更改融合的 kafka-rest 序列化程序？我想将融合的 avro 序列化程序交换为我的自定义序列化程序，但我检查了生产者池（https://github.com/confluentinc/kafka-rest/blob/2.x/src/main/java/io/confluent/kafkarest/ProducerPool.java）。

在构建 buildAvroProducer 时，它要求使用 KafkaAvroSerializer，这是一个融合库。所以似乎不可能在没有代码更改的情况下自定义它（比如简单地在类路径中交换 jar 或 sth） 不确定这个要求是否公平，并且想知道它是否在路线图上。

Answer 1

你说得对，目前这是不可能的。这组序列化程序经过硬编码以映射到一组内容类型。您需要更改代码以支持替代序列化程序。