如何为 kafka 消费者添加自定义消息反序列化器（使用 sarama lib）

【问题标题】：How to add custom message deserializer for kafka consumer(using sarama lib)如何为 kafka 消费者添加自定义消息反序列化器（使用 sarama lib）
【发布时间】：2020-05-21 12:21:38
【问题描述】：

序列化消息由 java 微服务生成，我需要在另一个用 golang 编写的服务中使用相同的消息
我在 golang 中为 kafka 消费者使用 sarama lib，我收到了消息，但由于通过生成服务进行序列化而导致消息失真
需要帮助将自定义反序列化器添加到消费者以接收 Go 中的传入消息。

【问题讨论】：

标签： go apache-kafka consumer sarama

【解决方案1】：

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

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

【讨论】：