public static void main()

in docker/data-generator/src/main/java/org/apache/flink/playground/datagen/DataGenerator.java [36:48]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  public static void main(String[] args) {
    Producer producer = new Producer(KAFKA, TOPIC);

    Runtime.getRuntime()
        .addShutdownHook(
            new Thread(
                () -> {
                  LOG.info("Shutting down");
                  producer.close();
                }));

    producer.run();
  }