void registerThread()

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

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

  void registerThread() {
    try {
      consumerAndRecords.get();
    } catch (Exception e) {
      logger.error(e.getMessage());
      e.printStackTrace();
    }
  }