CodeReview - Initial Commit for Kafka Integration Application
1. Partial REST API implementation
2. Partial Event Manager backend implementation
Change-Id: Ieaf703f7a3f6e296aea8ffcf155c7a1b603236ca
diff --git a/apps/kafka-integration/src/main/resources/definitions/KafkaRegistration.json b/apps/kafka-integration/src/main/resources/definitions/KafkaRegistration.json
new file mode 100644
index 0000000..a81fd11
--- /dev/null
+++ b/apps/kafka-integration/src/main/resources/definitions/KafkaRegistration.json
@@ -0,0 +1,5 @@
+{
+ "type": "string",
+ "title": "KafkaRegistration",
+ "example": "forwardingApp"
+}
\ No newline at end of file
diff --git a/apps/kafka-integration/src/main/resources/definitions/KafkaSubscription.json b/apps/kafka-integration/src/main/resources/definitions/KafkaSubscription.json
new file mode 100644
index 0000000..819ca77
--- /dev/null
+++ b/apps/kafka-integration/src/main/resources/definitions/KafkaSubscription.json
@@ -0,0 +1,23 @@
+{
+ "type": "object",
+ "title": "KafkaSubscription",
+ "required": [
+ "appName",
+ "groupId",
+ "eventType"
+ ],
+ "properties": {
+ "appName": {
+ "type": "string",
+ "example": "forwardingApp"
+ },
+ "groupId": {
+ "type": "string",
+ "example": "18285435-2c62-4684-96dd-fb03b7cd0c83"
+ },
+ "eventType": {
+ "type": "string",
+ "example": "DEVICE"
+ }
+ }
+}
\ No newline at end of file