private String getOffsetMapString()

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

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

    private String getOffsetMapString() {
      StringBuilder sb = new StringBuilder();
      sb.append(getName()).append(" current offsets map: ");
      for (Map.Entry<TopicPartition, OffsetAndMetadata> entry : offsets.entrySet()) {
        sb.append("p").append(entry.getKey().partition()).append('-')
            .append(entry.getValue().offset()).append(' ');
      }
      return sb.toString();
    }