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