flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java [175:182]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        requireNonNull(element);

        lock.lock();
        try {
            if (open) {
                elements.addLast(element);
                if (elements.size() == 1) {
                    nonEmpty.signalAll();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java [199:206]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        requireNonNull(element);

        lock.lock();
        try {
            if (open) {
                elements.addLast(element);
                if (elements.size() == 1) {
                    nonEmpty.signalAll();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -