public void onCompletion()

in flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java [475:488]

• 13 lines of code
• 4 McCabe index (conditional complexity)

  public void onCompletion(RecordMetadata metadata, Exception exception) {
    if (exception != null) {
      logger.warn("Error sending message to Kafka {} ", exception.getMessage());
    }

    if (logger.isDebugEnabled()) {
      long eventElapsedTime = System.currentTimeMillis() - startTime;
      if (metadata != null) {
        logger.debug("Acked message partition:{} ofset:{}", metadata.partition(),
                metadata.offset());
      }
      logger.debug("Elapsed time for send: {}", eventElapsedTime);
    }
  }