if (offered) {
            return SUCCESS_STATUS;
        } else {
            statsClient.increment("readQueueSink.push.failures");
            return new FailureStatus(new RuntimeException(String.format("%s queue is full with capacity: %d", config.getName(), recordQueue.size())));