From 565ec734f46a15bb3c87fe02a32613fc86c0eb22 Mon Sep 17 00:00:00 2001 From: Piotr Jaszczyk Date: Thu, 14 Mar 2019 14:34:35 +0100 Subject: Kafka streams parsers - additions Change-Id: I98ca661682b41d76d3de668d6faeb6ebe02f92a8 Issue-ID: DCAEGEN2-1341 Signed-off-by: Piotr Jaszczyk --- .../src/test/resources/streams/kafka_invalid_type.json | 7 +++++++ .../cbs-client/src/test/resources/streams/kafka_sink.json | 4 ++++ .../test/resources/streams/kafka_sink_invalid_type.json | 7 ------- .../src/test/resources/streams/kafka_source.json | 14 ++++++++++++++ 4 files changed, 25 insertions(+), 7 deletions(-) create mode 100644 rest-services/cbs-client/src/test/resources/streams/kafka_invalid_type.json delete mode 100644 rest-services/cbs-client/src/test/resources/streams/kafka_sink_invalid_type.json create mode 100644 rest-services/cbs-client/src/test/resources/streams/kafka_source.json (limited to 'rest-services/cbs-client/src/test/resources/streams') diff --git a/rest-services/cbs-client/src/test/resources/streams/kafka_invalid_type.json b/rest-services/cbs-client/src/test/resources/streams/kafka_invalid_type.json new file mode 100644 index 00000000..0ee88adb --- /dev/null +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_invalid_type.json @@ -0,0 +1,7 @@ +{ + "type": "message_router", + "kafka_info": { + "bootstrap_servers": "dmaap-mr-kafka-0:6060,dmaap-mr-kafka-1:6060", + "topic_name": "HVVES_PERF3GPP" + } +} diff --git a/rest-services/cbs-client/src/test/resources/streams/kafka_sink.json b/rest-services/cbs-client/src/test/resources/streams/kafka_sink.json index b60388d5..e7b45508 100644 --- a/rest-services/cbs-client/src/test/resources/streams/kafka_sink.json +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_sink.json @@ -1,5 +1,9 @@ { "type": "kafka", + "aaf_credentials": { + "username": "the user", + "password": "the passwd" + }, "kafka_info": { "client_role": "com.dcae.member", "client_id": "1500462518108", diff --git a/rest-services/cbs-client/src/test/resources/streams/kafka_sink_invalid_type.json b/rest-services/cbs-client/src/test/resources/streams/kafka_sink_invalid_type.json deleted file mode 100644 index 0ee88adb..00000000 --- a/rest-services/cbs-client/src/test/resources/streams/kafka_sink_invalid_type.json +++ /dev/null @@ -1,7 +0,0 @@ -{ - "type": "message_router", - "kafka_info": { - "bootstrap_servers": "dmaap-mr-kafka-0:6060,dmaap-mr-kafka-1:6060", - "topic_name": "HVVES_PERF3GPP" - } -} diff --git a/rest-services/cbs-client/src/test/resources/streams/kafka_source.json b/rest-services/cbs-client/src/test/resources/streams/kafka_source.json new file mode 100644 index 00000000..379dbef1 --- /dev/null +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_source.json @@ -0,0 +1,14 @@ +{ + "type": "kafka", + "aaf_credentials": { + "username": "the user", + "password": "the passwd" + }, + "kafka_info": { + "client_role": "com.dcae.member", + "client_id": "1500462518108", + "bootstrap_servers": "dmaap-mr-kafka-0:6060,,dmaap-mr-kafka-1:6060,", + "topic_name": "HVVES_PERF3GPP", + "consumer_group_id": "nokia-perf3gpp-processor" + } +} -- cgit