kakfa test improve 15/91915/1
authorZhangZihao <zhangzihao@chinamobile.com>
Wed, 24 Jul 2019 07:03:56 +0000 (15:03 +0800)
committerZhangZihao <zhangzihao@chinamobile.com>
Wed, 24 Jul 2019 07:04:13 +0000 (15:04 +0800)
Change-Id: I76f8094c32b82812069ff00b9ec1c9618962771a
Issue-ID: DCAEGEN2-1631
Signed-off-by: ZhangZihao <zhangzihao@chinamobile.com>
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java

index 0aefa1a..b210417 100644 (file)
@@ -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