Java中读取Struct类型数据：从Kafka Avro数据提取键值方法

嗨，这个问题我熟！Kafka Connect的Struct其实是个很直观的结构，要提取里面的键值对非常简单，给你几种常用的方法：

这是最直接的方式，用Struct.get(String fieldName)方法就能拿到对应的值，比如你的示例Struct{f1=value3}，代码可以这么写：

import org.apache.kafka.connect.data.Struct;

// 假设你已经从Kafka中拿到了这个Struct实例
Struct structData = ...; 

// 提取f1字段的值
Object f1Value = structData.get("f1");
// 如果确定值的类型是String，还可以直接强转
String f1StrValue = (String) structData.get("f1");

要是担心字段不存在会抛出异常，还可以用getOrDefault方法设置兜底的默认值：

// 当f1字段不存在时，返回"default_value"
Object f1Value = structData.getOrDefault("f1", "default_value");

如果你的Struct字段不固定，想一次性拿到所有键值对，可以通过它的Schema来遍历所有字段：

import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.data.Struct;

Struct structData = ...;
Schema schema = structData.schema();

// 遍历Schema中的所有字段，逐个提取键值
for (Schema.Field field : schema.fields()) {
    String fieldName = field.name();
    Object fieldValue = structData.get(field);
    System.out.printf("字段名：%s，对应值：%s%n", fieldName, fieldValue);
}

这种方式不管Struct里有多少字段，都能全部捞出来，特别适合处理结构不固定的场景。

如果想避免强转出错，还可以用Struct提供的类型专属get方法，比如：

• 提取字符串：structData.getString("f1")
• 提取32位整数：structData.getInt32("f1")
• 提取布尔值：structData.getBoolean("f1")
  这些方法会自动校验字段类型，如果类型不匹配会抛出DataException，能帮你快速定位类型错误的问题。

内容的提问来源于stack exchange，提问作者NoName