java - 带有 Kinesis 的 Spring Cloud 功能

Question

我正在尝试通过带有 Spring Cloud Function 的 AWS Lambda 收听来自 AWS Kinesis Streams 的数据。我无法将来自 Kinesis 的输入映射到我的处理程序。

MyHandler.java

public class RequestHandler extends SpringBootKinesisEventHandler<Payload, List<ABC>> {
}

映射器功能

@Bean
public Function<List<Payload>, Void> abc() {
    return value -> {
        value.forEach(payload ->abc.abc(payload.getAbcs()) );
        return null;
    };

这Payload是我自己的 POJO。

任何帮助都会很有用。