diff options
Diffstat (limited to 'components/datalake-handler/feeder')
| -rw-r--r-- | components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java index 0aefa1ae..b2104177 100644 --- a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java +++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java @@ -60,6 +60,20 @@ public class KafkaConfigTest { assertNotEquals(testKafkaConfig, testKafkaConfig2); assertNotEquals(testKafkaConfig, null); assertNotEquals(testKafkaConfig.hashCode(), testKafkaConfig2.hashCode()); + assertEquals(BROKER_KAFKA, testKafkaConfig.getBrokerList()); + assertNotEquals("", testKafkaConfig.getExcludedTopic()); + assertEquals(true, testKafkaConfig.isSecure()); + assertEquals("testLogin", testKafkaConfig.getLogin()); + assertEquals("test", testKafkaConfig.getName()); + assertNotEquals("test", testKafkaConfig.getIncludedTopic()); + assertEquals("testGroup", testKafkaConfig.getGroup()); + assertEquals(true, testKafkaConfig.isEnabled()); + assertNotEquals("", testKafkaConfig.getConsumerCount()); + assertEquals(1, testKafkaConfig.getId()); + assertNotEquals("", testKafkaConfig.getPass()); + assertNotEquals("test", testKafkaConfig.getSecurityProtocol()); + assertEquals(ZOO_KEEPER, testKafkaConfig.getZooKeeper()); + assertNotEquals(null, testKafkaConfig.getTimeout()); } }
\ No newline at end of file |