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

时间：2024-01-17 17:34:10

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

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

例如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);

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

例如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);

上一篇：云日志服务 LTS-LTS-Flink-Connector参数说明:WITH参数

下一篇：云日志服务 LTS-智能冷存储:开启智能冷存储