什么形式的信息对于向Kafka传递价值观是好的？

Question

我目前有一个开发环境如下所示。

• Spring-Boot 2.x
• Spring-Kafka 2.5.5
• Kafka版本2.5.1
• 生产者/使用者密钥序列化器/反序列化器=字符串(De)序列化器.类
• 生产者/使用者值Serializer/Deserializer=Json(De)Serializer.class

当生产者发送Kafka消息时，自定义DTO（或POJO）通过ObjectMapper.WriteValueAsString(customDto)转换为JSON String类型。

• ProducerFactory
• kafkatemplate

ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, msg); // The message is a JSON String variable made with ObjectMapper.

ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send(record);

当使用者收到JSON字符串消息时，通过ObjectMapper.ReadValue(message，CustomDTO.class)将其转换为相应的DTO（或POJO）并接收。

• ConsumerFactory

或者有没有一种方法可以直接发送和接收自定义DTO而不需要转换？我想使用泛型类型。怎么样？

Answer 1

有一种更好的方法通过Kafka发送复杂的类型，它包括一个可以自动序列化和去杀菌的结构。

1. 使用Avro架构https://Avro.apache.org/
2. 添加汇合模式注册表以处理序列化/反序列化过程和验证。合流

看看这个例子，看看它是多么的干净和高效。