Java Lambda处理Kinesis事件时无法读取Records记录问题咨询

核心原因 #

• 依赖版本不兼容：你使用的aws-lambda-java-events 1.3.0属于早期版本，和aws-java-sdk-core 1.11.619的序列化逻辑存在兼容性问题，无法将事件结构中大写开头的Records字段正确映射到KinesisEvent类的对应属性上，导致getRecords()返回null。
• 依赖冲突：pom中引入的aws-java-sdk-events是处理CloudWatch事件的SDK包，和Lambda接收事件专用的aws-lambda-java-events属于不同组件，两者存在类定义冲突，会干扰Kinesis事件的反序列化过程。

修复步骤 #

1. 移除pom中无用的冲突依赖：

<!-- 删掉该依赖 -->
<dependency>
  <groupId>com.amazonaws</groupId>
  <artifactId>aws-java-sdk-events</artifactId>
  <version>1.11.619</version>
</dependency>

2. 升级aws-lambda-java-events到和1.11.x系列SDK兼容的版本，示例如下：

<dependency>
  <groupId>com.amazonaws</groupId>
  <artifactId>aws-lambda-java-events</artifactId>
  <version>2.2.9</version>
</dependency>

3. 重新打包部署Lambda即可正常调用kinesisEvent.getRecords()获取记录列表。

临时验证方案 #

如果调整依赖后仍有问题，可以先将Handler的输入类型修改为Map<String, Object>直接接收原始事件，验证事件本身的结构正常，排除其他配置问题：

public class RequestEventHandler implements RequestHandler<Map<String, Object>, Void> {
  @Override
  public Void handleRequest(Map<String, Object> event, Context context) {
    System.out.println("Records字段内容：" + event.get("Records"));
    return null;
  }
}

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