云日志服务 LTS-使用Java SDK管理消费组:按照不同的消费需求，请使用不同的构造方法

时间：2025-01-26 10:50:19

云日志服务 LTS

按照不同的消费需求，请使用不同的构造方法

指定消费开始时间，不指定结束时间。

例如StartTimeNs = 0L，即从头开始一直拉取到当前最新。如果还有新的日志产生就一直拉取。

例如StartTimeNs = 1685444710000000000L，即从1685444710000000000纳秒所代表的时间开始拉取，一直拉取到当前最新。如果还有新的日志产生就一直拉取。

// 不设置batchSize，即每次拉取1000条LogConsumerConfig config = new LogConsumerConfig("TEST_REGION_NAME", "TEST_PROJECT","TEST_ LOG _GROUP_ID","TEST_LOG_STREAM_ID","AC CES S_KEY_ID","ACCESS_KEY_SECRET","CONSUMER_GROUP_NAME", 1685444710000000000L);// 设置batchSize = 500，即每次拉取500条LogConsumerConfig config = new LogConsumerConfig("TEST_REGION_NAME", "TEST_PROJECT","TEST_LOG_GROUP_ID","TEST_LOG_STREAM_ID","ACCESS_KEY_ID","ACCESS_KEY_SECRET","CONSUMER_GROUP_NAME", 1685444710000000000L, 500);/* 如果需要按照日志组/日志流名称消费，此功能仅1.0.3版本以上才支持LogConsumerConfig config = new LogConsumerConfig("TEST_REGION_NAME", "TEST_PROJECT","TEST_LOG_GROUP_NAME","TEST_LOG_STREAM_NAME", true ,"ACCESS_KEY_ID","ACCESS_KEY_SECRET","CONSUMER_GROUP_NAME", 1685444710000000000L, 500); */

指定消费开始时间，且指定结束时间。

例如StartTimeNs = 0L，EndTimeNs=1685444710000000000L。即从头开始一直拉取到EndTimeNs所代表的时间。不会拉取这段时间范围以外的数据。

例如StartTimeNs = 1685444710000000000L，EndTimeNs=1685445470192043318L。即从StartTimeNs所代表的时间开始一直拉取到EndTimeNs所代表的时间。不会拉取这段时间范围以外的数据。

// 不设置batchSize，即每次拉取1000条LogConsumerConfig config = new LogConsumerConfig("TEST_REGION_NAME", "TEST_PROJECT","TEST_LOG_GROUP_ID","TEST_LOG_STREAM_ID","ACCESS_KEY_ID","ACCESS_KEY_SECRET","CONSUMER_GROUP_NAME",1685444710000000000L, 1685445470192043318L);// 设置batchSize = 500，即每次拉取500条LogConsumerConfig config = new LogConsumerConfig("TEST_REGION_NAME", "TEST_PROJECT","TEST_LOG_GROUP_ID","TEST_LOG_STREAM_ID","ACCESS_KEY_ID","ACCESS_KEY_SECRET","CONSUMER_GROUP_NAME",1685444710000000000L, 1685445470192043318L, 500);/* 如果需要按照日志组/日志流名称消费，此功能仅1.0.3版本以上才支持LogConsumerConfig config = new LogConsumerConfig("TEST_REGION_NAME", "TEST_PROJECT","TEST_LOG_GROUP_NAME","TEST_LOG_STREAM_NAME", true ,"ACCESS_KEY_ID","ACCESS_KEY_SECRET","CONSUMER_GROUP_NAME",1685444710000000000L, 1685445470192043318L, 500); */

上一篇：云日志服务 LTS-云日志服务Web SDK:NPM方式安装SDK

下一篇：云日志服务 LTS-Flink消费:DynamicLtsTableFactory支持SQL作业