private void saveOffsets()

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

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

    private void saveOffsets(TopicPartition tp, OffsetAndMetadata oam) {
      offsets.put(tp,oam);
      if (logger.isTraceEnabled()) {
        logger.trace(getOffsetMapString());
      }
    }