Kinesis S3持久性 这本质上是此处的amazon-kinesis-connector S3示例的简化版本: : 有一些细微的修改: 它使用行家创建一个胖子罐。 您可以为配置传递s3 URI(s3://my-bucket/config.properties)。 您可以将其构建到Docker容器中。 它将在每个事件之后添加换行符。 它将对s3对象和AES SSE加密增加14天的有效期。 就目前而言,持久性将读取每个消息作为单个字符串,并将其写入S3。
评论0
最新资源