Apache Kafka + Kryo序列號

Question

我對Kafka和Kryo​​非常陌生。我一直在使用默認的Kafka Serializer來處理Kafka上的簡單String消息，但是我試圖使用Kryo Serialization而沒有成功。

有人可以解釋或顯示一個通過kryo序列化（生產者和消費者）向卡夫卡發送一些Java對象的例子嗎？

我已經看到了有關同一主題沒有答案的其他問題，我不能評論它。提前道歉。

謝謝。

Answer 1

我可能從問題中脫口而出，但想提供一些我們的經驗。

我們從Kafka + Kyro開始，儘管肯定可以完成，但我們發現使用Kyro進行模式管理可能會長期存在麻煩。所以我們寧願去用Jackson系列化器（org.codehaus.jackson.map.ObjectMapper）。

要實現凱洛串行你只需要繼承卡夫卡的串行

import org.apache.kafka.common.serialization.Serializer; 
    public class KryoSerializer implements Serializer<YourObject> 

，並覆蓋序列化方法。

祝你好運。