日志服务Flink Connector《支持Exactly Once》
阿里云日志服务是针对实时数据一站式服务,用户只需要将精力集中在分析上,过程中数据采集、对接各种存储计算、数据索引和查询等琐碎工作等都可以交给日志服务完成。 日志服务中最基础的功能是LogHub,支持数据实时采集与消费,实时消费家族除 Spark Streaming、Storm、StreamCompute(Blink外),目前新增Flink啦。 Flink Connector Flink log connector是阿里云日志服务提供的,用于对接flink的工具,包括两部分,消费者(Consumer)和生产者(Producer)。 消费者用于从日志服务中读取数据,支持exactly once语义,支持shard负载均衡.生产者用于将数据写入日志服务,使用connector时,需要在项目中添加maven依赖: <dependency>
