summaryrefslogtreecommitdiffstats
path: root/components/datalake-handler/feeder/src
diff options
context:
space:
mode:
authorZhangZihao <zhangzihao@chinamobile.com>2019-07-24 15:03:56 +0800
committerZhangZihao <zhangzihao@chinamobile.com>2019-07-24 15:04:13 +0800
commitf3c010de447f292bc0f136fc3e29b8239667065d (patch)
treef5f0293e11ee9f246527d2f961bbebb21a941972 /components/datalake-handler/feeder/src
parent8891e4097a3655adf434734efa38b0e7cb76e6c5 (diff)
kakfa test improve
Change-Id: I76f8094c32b82812069ff00b9ec1c9618962771a Issue-ID: DCAEGEN2-1631 Signed-off-by: ZhangZihao <zhangzihao@chinamobile.com>
Diffstat (limited to 'components/datalake-handler/feeder/src')
-rw-r--r--components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java14
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