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> 

并覆盖序列化方法。

祝你好运。