Функция весеннего облака с 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.

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

0 ответов

Другие вопросы по тегам