public boolean hasNext()

in pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/ConsumerIterator.java [62:76]

• 15 lines of code
• 4 McCabe index (conditional complexity)

    public boolean hasNext() {
        try {
            Message<byte[]> msg = consumer.receive(10, TimeUnit.MILLISECONDS);
            if (msg != null) {
                receivedMessages.offer(msg);
                return true;
            }
        } catch (PulsarClientException e) {
            if (log.isDebugEnabled()) {
                log.debug("Failed to receive message for {}-{}, {}", consumer.getTopic(), consumer.getSubscription(),
                        e.getMessage());
            }
        }
        return false;
    }