diff options
| author |   Piotr Jaszczyk <piotr.jaszczyk@nokia.com> | 2019-03-14 08:38:15 +0100 |
|---|---|---|
| committer | Piotr Jaszczyk <piotr.jaszczyk@nokia.com> | 2019-03-14 13:58:20 +0100 |
| commit | c852448b1e6ca5e28e0b0dab26c2af3d5af3f390 (patch) | |
| tree | bf50c6ddbb24eab14f4da96849a74c6088f1e338 /rest-services/cbs-client/src/test/resources | |
| parent | 9eb05b612d185d00ad6ad9deffc5a3ab5cf91a1e (diff) | |
Implement Kafka stream definition parsers
Change-Id: I43215c1c2494b6036deb004891fb76bfd2b74474
Issue-ID: DCAEGEN2-1341
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
Diffstat (limited to 'rest-services/cbs-client/src/test/resources')
5 files changed, 33 insertions, 0 deletions
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 new file mode 100644 index 00000000..b60388d5 --- /dev/null +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_sink.json @@ -0,0 +1,9 @@ +{ + "type": "kafka", + "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" + } +} 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 new file mode 100644 index 00000000..0ee88adb --- /dev/null +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_sink_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_minimal.json b/rest-services/cbs-client/src/test/resources/streams/kafka_sink_minimal.json new file mode 100644 index 00000000..da8dd4fe --- /dev/null +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_sink_minimal.json @@ -0,0 +1,7 @@ +{ + "type": "kafka", + "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_missing_child.json b/rest-services/cbs-client/src/test/resources/streams/kafka_sink_missing_child.json new file mode 100644 index 00000000..d2591b3a --- /dev/null +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_sink_missing_child.json @@ -0,0 +1,3 @@ +{ + "type": "kafka" +} diff --git a/rest-services/cbs-client/src/test/resources/streams/kafka_source_minimal.json b/rest-services/cbs-client/src/test/resources/streams/kafka_source_minimal.json new file mode 100644 index 00000000..da8dd4fe --- /dev/null +++ b/rest-services/cbs-client/src/test/resources/streams/kafka_source_minimal.json @@ -0,0 +1,7 @@ +{ + "type": "kafka", + "kafka_info": { + "bootstrap_servers": "dmaap-mr-kafka-0:6060,dmaap-mr-kafka-1:6060", + "topic_name": "HVVES_PERF3GPP" + } +} |