Kafka如何序列化和反序列化复杂对象？

Kafka 提供了多种序列化和反序列化方式，包括 JSON、Avro、Protobuf 等，可以根据具体需要选择合适的方式。以下以 Avro 为例，演示如何序列化和反序列化复杂对象。

首先，在项目中引入以下依赖：

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-avro-serializer</artifactId>
    <version>${confluent.version}</version>
</dependency>

其中，${confluent.version} 可以根据具体情况进行调整。

然后，定义一个 Avro schema，用于描述要序列化和反序列化的复杂对象。例如：

{
  "type": "record",
  "name": "Person",
  "fields": [
    {"name": "name", "type": "string"},
    {"name": "age", "type": "int"},
    {
      "name": "address",
      "type": {
        "type": "record",
        "name": "Address",
        "fields": [
          {"name": "street", "type": "string"},
          {"name": "city", "type": "string"},
          {"name": "state", "type": "string"},
          {"name": "zip", "type": "string"}
        ]
      }
    }
  ]
}

接下来，定义一个 Java 类来代表上述 schema 对应的对象，例如：

public class Person {
    private String name;
    private int age;
    private Address address;

    // getters and setters
}

public class Address {
    private String street;
    private String city;
    private String state;
    private String zip;

    // getters and setters
}

然后，在生产者中，使用 Avro 序列化器将复杂对象序列化为 Avro 格式的字节数组，然后将其发送给 Kafka，例如：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:909