使用Sarama库为Kafka消费者自定义消息反序列化器

大家好，我们又见面了啊~本文《使用Sarama库为Kafka消费者自定义消息反序列化器》的内容中将会涉及到等等。如果你正在学习Golang相关知识，欢迎关注我，以后会给大家带来更多Golang相关文章，希望我们能一起进步！下面就开始本文的正式内容~

序列化消息由 java 微服务生成，我需要在用 golang 编写的另一个服务中使用相同的消息

我在 golang 中为 kafka 消费者使用 sarama lib，我收到消息，但由于生产服务的序列化，它被扭曲了

需要帮助向消费者添加自定义反序列化器以接收 Go 中的传入消息。

解决方案

您可以尝试在发布消息之前在消息头中添加序列化类型。

假设您想发布一个缓冲的 json 字符串，您可以添加/设置标头内容类型 json。因此，当您从另一个服务消费消息时，首先读取带有关键内容类型的标头，如果值为 json，则使用 json 序列化。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~