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