S3 Sink Connector提取Envelope嵌套字段分区报错解决方案

按以下优先级定位根因：

• 第一优先级核对字段路径：从给出的Avro Schema可以看到，消息根层级只有before、after两个字段，createdAt是嵌套在这两个结构体内部的二级字段，当前配置直接指定timestamp.field: "createdAt"只会查找根级字段，必然触发找不到嵌套字段的错误。
• 第二优先级核对转换器配置：当前配置使用JsonConverter且关闭了schema解析能力（value.converter.schemas.enable: "false"），如果上游写入的是Avro格式的Debezium CDC消息，转换器和序列化格式不匹配会直接导致连接器无法正确解析消息结构；就算上游输出是JSON格式，关闭schema支持后连接器也无法识别嵌套字段的元数据，同样会导致字段查找失败。
• 第三优先级核对字段格式兼容性：createdAt是Debezium生成的io.debezium.time.ZonedTimestamp类型（带时区的时间字符串），要确认时间提取器可以正常解析该格式，避免字段找到后触发时间格式转换错误。

按顺序修改对应配置项即可解决问题：

1. 修正嵌套字段路径
   Confluent自带的TimeBasedPartitioner支持通过.分隔的路径指定嵌套字段，由于Debezium CDC消息的最新行数据存储在after字段下，删除操作的after值为null，已经配置的behavior.on.null.values: "ignore"会自动忽略这类删除事件，直接将时间字段配置修改为嵌套路径：

"timestamp.field": "after.createdAt"

2. 修正消息转换器配置
   如果上游topic里的消息是Avro序列化格式（和给出的Avro Schema对应），替换value转换器为Avro转换器，并配置实际环境的Schema Registry地址：

"value.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url": "http://<替换为实际Schema Registry服务地址>:8081"

如果上游topic里的消息已经是JSON格式，不需要换转换器，但是要开启schema解析能力，否则连接器无法识别嵌套结构：

"value.converter.schemas.enable": "true"

3. 可选容错配置
   为了避免少量消息after.createdAt为空导致任务报错，增加兜底时间提取配置，字段为空时自动用连接器处理消息的系统时间分区：

"timestamp.fallback": "Wallclock"

• 配置更新重启连接器后，观察任务日志，确认没有字段找不到的异常
• 进入目标S3存储桶，检查生成的对象路径是否符合YYYY/MM/dd的时间分区格式
• 抽样下载分区内的文件，核对消息的createdAt时间和所属分区的时间范围是否匹配

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