如何配置匯合kafka休息序列化程序？

Question

是否可以更改匯合的kafka-rest序列化程序？我想將匯合avro串行器交換到我的定製串行器，但我檢查了生產者池（https://github.com/confluentinc/kafka-rest/blob/2.x/src/main/java/io/confluent/kafkarest/ProducerPool.java）。

當構建buildAvroProducer時，它要求KafkaAvroSerializer，它是一個融合的lib。所以似乎無法在沒有代碼更改的情況下對其進行定製（就像在類路徑或者某處簡單地交換jar） 不確定這個要求是否公平，並且不知道它是否在路線圖上。

Answer 1

你是對的，這是不可能的。這組序列化器被硬編碼以映射到一組內容類型。您需要更改代碼以支持其他序列化程序。