diff options
| author |   Guobiao Mo <guobiaomo@chinamobile.com> | 2019-06-19 12:59:46 -0700 |
|---|---|---|
| committer | Guobiao Mo <guobiaomo@chinamobile.com> | 2019-06-19 12:59:46 -0700 |
| commit | f0a4690a93e9ceed517530996f46b2ebfa7348b9 (patch) | |
| tree | d348ebd713163be281020edbc74ad551d2b3b84c /components/datalake-handler/feeder/src/test/java/org | |
| parent | ef09439c31588547a1161365c8ff15677a1376c0 (diff) | |
Connect to secured Kafka
Issue-ID: DCAEGEN2-1632
Change-Id: I85767916fbf3b8f874ac367b7161b50a272d8595
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
Diffstat (limited to 'components/datalake-handler/feeder/src/test/java/org')
| -rw-r--r-- | components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/PullerTest.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/PullerTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/PullerTest.java index fab5d4cd..4a5553fc 100644 --- a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/PullerTest.java +++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/PullerTest.java @@ -73,6 +73,9 @@ public class PullerTest { when(config.getDmaapKafkaHostPort()).thenReturn("test:1000"); when(config.getDmaapKafkaGroup()).thenReturn("test"); + when(config.getDmaapKafkaLogin()).thenReturn("login"); + when(config.getDmaapKafkaPass()).thenReturn("pass"); + when(config.getDmaapKafkaSecurityProtocol()).thenReturn("TEXT"); Thread thread = new Thread(puller); thread.start(); |