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です。

どんなヘルプも役に立ちます。