rest - 如何配置 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

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