private void poll()

in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java [614:623]

• 10 lines of code
• 2 McCabe index (conditional complexity)

    private void poll() {
      logger.trace("Polling with timeout: {}ms channel-{}", pollTimeout, getName());
      try {
        records = consumer.poll(Duration.ofMillis(pollTimeout));
        recordIterator = records.iterator();
        logger.debug("{} returned {} records from last poll", getName(), records.count());
      } catch (WakeupException e) {
        logger.trace("Consumer woken up for channel {}.", getName());
      }
    }