java - 带有 Kinesis 的 Spring Cloud 功能
问题描述
我正在尝试通过带有 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。
任何帮助都会很有用。
解决方案
推荐阅读
- java - 为什么较新的 JavaSE 版本支持 Swing,但 JavaFX 不支持?
- docker - 如何配置 Nginx 容器以使用自签名证书为在主机上运行的应用程序提供服务?
- javascript - 用另一个 DOM 完全替换 HTML DOM
- python - Selenium 无法在 Twitter 注册页面中找到名称字段
- wordpress - Wordpress/Pardot/Contact Form 7(需要验证号码和电子邮件的插件)
- jpeg - 为什么 libjpeg 不正确地存储我的图像数组?
- pdf - 如何使用Java iText在pdf文件中将字体名称作为字符串传递
- python - 根据常量 python 列表设置张量值的优雅方法
- python - 在 Django 中使用 python 创建本地文件
- java - 如何定义 JTable 的 Column 的数据类型与 MySql 数据库相同?