Я пытаюсь прослушать данные, поступающие в 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.
Любая помощь будет полезна.