diff options
author | 2019-07-26 00:54:06 +0000 | |
---|---|---|
committer | 2019-07-26 00:54:06 +0000 | |
commit | b00de662acf33320ffb1218d931c76894f2d1280 (patch) | |
tree | 2b37802bf17b796b6d0321b49224c9f63e72d5a2 | |
parent | 96887c46e821cedb43cac026abcebb42649a5495 (diff) | |
parent | f3c010de447f292bc0f136fc3e29b8239667065d (diff) |
Merge "kakfa test improve"
-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 |