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();*/
    }

}