From f3c010de447f292bc0f136fc3e29b8239667065d Mon Sep 17 00:00:00 2001 From: ZhangZihao Date: Wed, 24 Jul 2019 15:03:56 +0800 Subject: kakfa test improve Change-Id: I76f8094c32b82812069ff00b9ec1c9618962771a Issue-ID: DCAEGEN2-1631 Signed-off-by: ZhangZihao --- .../java/org/onap/datalake/feeder/dto/KafkaConfigTest.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) (limited to 'components/datalake-handler/feeder') 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 -- cgit 1.2.3-korg