package com.nisum; import com.nisum.job.KafkaDataReaderJob; import com.nisum.job.KafkaDataWriterJob; import io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException; import java.io.IOException; public class App { private static KafkaDataReaderJob kafkaDataReaderJob; private static KafkaDataWriterJob kafkaDataWriterJob; public static void main(String[] args) throws IOException, RestClientException { kafkaDataReaderJob = new KafkaDataReaderJob(); kafkaDataReaderJob.read(); /* kafkaDataWriterJob = new KafkaDataWriterJob(); kafkaDataWriterJob.run();*/ } }