KafkaStreamingJob.java

// KafkaStreamingJob.java
...
        // execute program
        env.execute(
            String.format(
                "%s [ETL] (Topic %s | Mode %s | Format: %s): ",
                KafkaStreamingJob.class.getName(),
                KAFKA_TOPIC,
                KAFKA_FETCH_MODE,
                FORMAT
            )
        );
...