kakfa test improve

Change-Id: I76f8094c32b82812069ff00b9ec1c9618962771a
Issue-ID: DCAEGEN2-1631
Signed-off-by: ZhangZihao <zhangzihao@chinamobile.com>

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