是否可以更改合流的kafka rest序列化程序?我想将合流avro序列化程序交换到我的定制序列化程序,但我检查了producer池内部(https://github.com/confluentinc/kafka-rest/blob/2.x/src/main/java/io/confluent/kafkarest/producerpool.java).
在构建buildavroproducer时,它要求kafkaavroserializer,这是一个合流库。因此,似乎不可能在没有代码更改的情况下对其进行定制(比如在classpath中简单地交换jar或其他东西),不确定这个需求是否公平,不知道它是否在路线图上。
1条答案
按热度按时间nmpmafwu1#
你是对的,这是目前不可能的。序列化程序集被硬编码为Map到一组内容类型。您需要对代码进行更改以支持其他序列化程序。