如何在不使用Kafka的JsonSerializer的情况下向Kafka生成JSON对象

Question

问题出现在Kafka的配置需要序列化程序。config.put(producerconfig.value_serializer_class_config,null）；不起作用，JsonSerializer也不起作用，而字符串序列化程序将所有“转义为\”，这使得使用这些消息非常麻烦。

如何生成这些JSON对象？是否有一个简单的Kafka序列化程序配置？

Answer 1

执行config.put(producerconfig.value_serializer_class_config,null)这样的操作永远不会奏效，您需要告诉Kafka如何处理您提供的对象。

您可以显式地将自己的数据序列化为字节数组，然后用自己的序列化程序实现推送字节数组。

您需要实现org.apache.kafka.common.serialization.serializer接口，其中最有趣的方法如下所示：

@Override
byte[] serialize(String topic, YourXmlClass data) {
    return data.toByteArray(); // or something richer
}