Функция весеннего облака с Kinesis - PullRequest
0 голосов
/ 04 марта 2019

Я пытаюсь прослушать данные, поступающие в AWS Kinesis Streams, через мою AWS Lambda с Spring Cloud Function.Я не могу отобразить вход, поступающий из 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.

Любая помощь будет полезна.

...