AWS Kinesis Lambda Transformation с использованием Java - один или несколько идентификаторов записей не были возвращены

Question

Ошибка ниже при обработке AWS kinesis - лямбда-функция для S3

One or more record Ids were not returned. Ensure that the Lambda function returns all received record Ids.

Ниже приведен мой фрагмент кода.

{
        List<KinesisFirehoseOutputRecord> results = event.getRecords().stream()
                .map(record -> {
                    KinesisFirehoseOutputRecord outRec = new KinesisFirehoseOutputRecord();
                    outRec.setRecordId(record.getRecordId());
                    outRec.setData(record.getData());
                    if (record.getData().toLowerCase().contains("moldovan")) {
                        outRec.setResult("Ok");
                    } else {
                        outRec.setResult("Dropped");
                    }


                    return outRec;
                }).collect(Collectors.toList());

        return new KinesisFirehoseResponse(results);
        }

если я уберу условие if else и добавлю outRec. setResult ("Ok"); работает нормально, как и ожидалось. Есть идеи, как решить эту проблему?