Spring Boot Kafka - 序列化和反序列化JSON_spring kafka json serializer

Spring Boot Kafka - 序列化和反序列化JSON

前言

在在Spring Boot应用集成Kafka读写消息 一文中说明了如何通过Spring Kafka来发送和接收字符串消息。

本文描述了如何通过Spring Kafka如何在发送消息时序列化JSON（将对象转换成JSON字节流），如何在接收数据时反序列化JSON（将JSON字节流转换成对象）。

配置JsonSerializer和JsonDeserializer

在application.yaml 中配置JsonSerializer和JsonDeserializer。

server:
  port: 8080
spring:
  kafka:
    consumer:
      bootstrap-servers: localhost:9092
      group-id: demo-group
      auto-offset-reset: earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
      properties:
        spring:
          json:
            trusted:
              packages: '*'

    producer:
      
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17