Производитель Kafka отправляет сообщение об истечении срока действия дуэта на 30003 мс с момента последнего добавления

Я использую Kafka 0.10.1.1 и пишу производителя тестов, но получаю ошибку в обратном вызове producer.send onCompletion:

        producer.send(record, new Callback() {
        @Override
        public void onCompletion(RecordMetadata metadata, Exception e) {
            if (e != null){
                System.out.println(e.getMessage());
            }
        }
    });

Производитель с конфигурацией: timeout.ms=30000, linger.ms=5, batch.size=1000

Получил следующее сообщение об ошибке:

Срок действия 1 записи (записей) для testtopic-2 истекает из-за того, что с момента последнего добавления прошло 30004 мс.

Но это сообщение об ошибке просто появлялось иногда. Иногда производитель может хорошо работать.