KafkaStreamingJob.java

Kafka Stream Job class:

// KafkaStreamingJob.java
...
        final KafkaConsumer kafkaConsumer = new KafkaConsumer(ConfigInstance.map);

        DataStream stream = env.addSource(
            kafkaConsumer.getKafkaConsumer()
        ).name("Kafka Source");
...