java - Apache Kafka + Kryo 序列化

Question

我对 Kafka 和 Kryo 非常陌生。我一直在使用默认的 Kafka 序列化器通过 Kafka 处理简单的字符串消息，但我尝试使用 Kryo 序列化但没有成功。

有人可以解释或向我展示一个使用 kryo 序列化(生产者和消费者)通过 Kafka 发送一些 java 对象的示例吗？

我在 stackoverflow 上看到了关于同一主题的其他问题，但没有答案，我无法对此发表评论。提前道歉。

谢谢。

Answer 1

我可能偏离了这个问题，但想提供一些我们的经验。

我们从 Kafka + Kyro 开始，虽然这当然可以做到，但我们发现从长远来看，使用 Kyro 进行模式管理可能会很麻烦。所以我们宁愿选择 Jackson Serilaizer (org.codehaus.jackson.map.ObjectMapper)。

要实现 Kyro 序列化器，您只需要继承 Kafka 的序列化器

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

并重写序列化方法。

祝你好运。