有没有办法从运动中消耗样本记录？

Question

我使用KCL编写了一个Amazon Kinesis消费者，KCL管理我的记录处理任务。它当前正在处理记录而不进行筛选。我正在寻找一种方法来处理样本记录，同时跳过其中的一些记录。

例如，如果总共有100条记录，我只想处理其中的1/10（10个样本记录）。

谢谢

Answer 1

据我所知，无法告诉Kinesis只返回一个随机的记录子集。所以，一旦记录返回给您，您就可以忽略这些记录。

在processRecords方法中，只需随机忽略9/10条记录：

public void processRecords(ProcessRecordsInput processRecordsInput) {
    processRecordsInput.records()
            .forEach(r -> if (generateRandomNumber()%10 == 0) process(r));
}

private int generateRandomNumber() {
    Random random = new Random();
    return random.nextInt(10);
}