...
It pulls data from Mongo DB and pushes to Kafka topics. It does not do any validation on data while fetching and pushing to Kafka topicstopic. It fetches all data from Mongo DB and pushes a single item at once. Till now, It iterates the over all the whole record records and pushes one record at a time without any validation.
...
After execution of the application we expect data population in Druid. For validation we have to make sure that record size number of records from Druid is matching to record count from Mongo-Kafka-Source-Connector log.
Deployment Details
It does not require any configuration requires below configurations for deployment. All props and config are implemented in application itself. Only deployment of this application can start it’s process and end itself.
...
Before executing this application, make sure that there is no ongoing data process is executing. All data processing from iFix should be processed before or and should stop to do any activity which can lead to data ingestion in Druid.
...