assertNotNull(config.getDmaapKafkaHostPort());
assertNotNull(config.getDmaapKafkaGroup());
assertTrue(config.getDmaapKafkaTimeout() > 0L);
- assertTrue(config.getDmaapCheckNewTopicIntervalInSec() > 0);
+ assertTrue(config.getDmaapCheckNewTopicInterval() > 0);
assertTrue(config.getKafkaConsumerCount() > 0);
assertNotNull(config.getRawDataLabel());
assertNotNull(config.getTimestampLabel());
assertNotNull(config.getElasticsearchType());
+ assertNotNull(config.getDatalakeVersion());
//HDFS
assertTrue(config.getHdfsBatchSize()>0);