public synchronized void start()

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

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

  public synchronized void start() {
    // instantiate the producer
    producer = new KafkaProducer<>(kafkaProps);
    if (useKafkaTransactions) {
      logger.info("Transactions enabled, initializing transactions");
      producer.initTransactions();
    }
    counter.start();
    super.start();
  }