Kafka producer正在发送protobuf和json消息。有没有一种方法可以识别消息的格式是protobuf还是json,然后进行相应的处理?
6yt4nkrj1#
使用ByteArrayDeserializer设置消费者。在你的轮询循环中放入一个try-catch并反序列化一个或另一个。。我建议先尝试Protobuf,因为我希望它的二进制格式比JSON更容易检测。否则,正如在评论中提到的,您将需要说服您的生产者添加额外的元数据,您可以解析
1条答案
按热度按时间6yt4nkrj1#
使用ByteArrayDeserializer设置消费者。
在你的轮询循环中放入一个try-catch并反序列化一个或另一个。。我建议先尝试Protobuf,因为我希望它的二进制格式比JSON更容易检测。
否则,正如在评论中提到的,您将需要说服您的生产者添加额外的元数据,您可以解析