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

Question

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

构建 buildAvroProducer 时，它要求 KafkaAvroSerializer，这是一个融合库。因此，似乎无法在不更改代码的情况下对其进行自定义（比如简单地在类路径中交换 jar 或其他） 不确定这个要求是否公平，并想知道它是否在路线图上。

Answer 1

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