private String getCommittedOffsetsString()

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

• 14 lines of code
• 3 McCabe index (conditional complexity)

    private String getCommittedOffsetsString() {
      StringBuilder sb = new StringBuilder();
      sb.append(getName()).append(" committed: ");
      for (TopicPartition tp : consumer.assignment()) {
        try {
          sb.append("[").append(tp).append(",")
              .append(consumer.committed(tp).offset())
              .append("] ");
        } catch (NullPointerException npe) {
          logger.debug("Committed {}", tp);
        }
      }
      return sb.toString();
    }