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

Question

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

标签： goapache-kafkaconsumersarama

Answer 1

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

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