检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
从最新的数据开始消费,此策略会忽略通道中已有数据 // EARLIEST,从最初的数据开始消费,此策略会获取通道中所有的有效数据 String offsetPolicy; // OBS文件输出路径,格式obs://bucket/path
从最新的数据开始消费,此策略会忽略通道中已有数据 // EARLIEST 从最初的数据开始消费,此策略会获取通道中所有的有效数据 String startingOffsets = params.get("startOffset");