private void commitOffsets()

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

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

    private void commitOffsets() {
      try {
        consumer.commitSync(offsets);
      } catch (Exception e) {
        logger.info("Error committing offsets.", e);
      } finally {
        logger.trace("About to clear offsets map.");
        offsets.clear();
      }
    }