kafka json序列化

Kafka是一个分布式流处理平台，它支持将数据发布到主题（Topic），然后消费者可以订阅并消费这些数据。对于JSON序列化，Kafka提供了一个内置的插件叫做`kafka-json-serde`，用于将JSON数据转换为Kafka消息，并将接收到的消息解析回JSON。

使用JSON序列化的步骤包括：

1. 配置生产者：在创建Kafka producer时，指定`key.serializer`和`value.serializer`属性为`org.apache.kafka.common.serialization.JsonSerializer`，这将负责把JSON对象转换成字节序列。

Properties props = new Properties();
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);

2. 配置消费者：同样地，消费者也需要配置对应的`key.deserializer`和`value.deserializer`为`JsonDeserializer`。

props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);

3. 数据编码：发送的数据需要是符合JSON规范的对象或数组，例如：

{
   "name": "John",
   "age": 30,
   "city": "New York"
}