fix: missing required fields

Signed-off-by: David Hontecillas <dhontecillas@gmail.com>

Author: dhontecillas

v2.13/backend/pubsub/kafka/publisher.json

@@ -8,10 +8,11 @@
   "properties": {
     "success_status_code": {
       "title": "Success Status Code",
-      "description": "http status code to return for a successful write in the queue",
+      "description": "HTTP status code to return for a successful write in the queue",
       "type": "number",
       "maximum": 201,
-      "minimum": 200
+      "minimum": 200,
+      "deafult": 200
     },
     "writer": {
       "title": "Writer",

v2.13/messaging/kafka/connection.json

@@ -4,6 +4,9 @@
   "title": "Kafka Reader Connection",
   "description": "Enterprise only. Defines how to connect to a Kafka cluster",
   "type": "object",
+  "required": [
+      "brokers",
+  ],
   "properties": {
     "brokers": {
       "title": "Brokers available to connect to",
@@ -19,7 +22,9 @@
       "$ref": "../../client_tls.json"
     },
     "sasl": {
+      "type": "object",
       "title": "SASL Connection options",
+      "description": "Enables to authenticate to the Kafka service using user and password",
       "$ref": "./sasl.json"
     },
     "dial_timeout": {

v2.13/messaging/kafka/consumer.json

@@ -20,7 +20,7 @@
     },
     "group_rebalance_strategies": {
       "title": "Group Rebalance Strategies",
-      "description": "the priority-ordered list of client-side consumer group balancing strategies that will be offered to the coordinator. The first strategy that all group members support will be chosen by the leader. Optionsare: range, roundrobin, and sticky",
+      "description": "the priority-ordered list of client-side consumer group balancing strategies that will be offered to the coordinator. The first strategy that all group members support will be chosen by the leader. Options are: `range`, `roundrobin`, and `sticky`",
       "default": [ "range" ],
       "type": "array",
       "items": {
@@ -47,6 +47,7 @@
     "isolation_level": {
       "title": "Isolation Level",
       "description": "supports 2 modes: `read_commited` to consume and return all messages in message channel, and `read_uncommited` to hide messages that are part of an aborted transaction",
+      "type": "string",
       "default": "read_commited",
       "enum": [ "read_commited", "read_uncommited" ]
     }

v2.13/messaging/kafka/reader.json

@@ -4,6 +4,10 @@
   "title": "Kafka Reader",
   "description": "Enterprise only. Defines how to read messages from a Kafka cluster",
   "type": "object",
+  "required": [
+      "connection",
+      "topics"
+  ],
   "properties": {
     "connection": {
       "title": "Connection details",

v2.13/messaging/kafka/sasl.json

@@ -7,8 +7,9 @@
   "properties": {
     "mechanism": {
       "title": "SASL  Mechanism",
-      "description": "The name of the enabled SASL mechanism. Possible values: OAUTHBEARER, PLAIN",
+      "description": "The name of the enabled SASL mechanism",
       "default": "PLAIN",
+      "type": "string",
       "enum": [ "PLAIN", "OAUTHBEARER" ]
     },
     "azure_event_hub": {

v2.13/messaging/kafka/writer.json

@@ -4,27 +4,28 @@
   "title": "Kafka Writer",
   "description": "Enterprise only. Defines how to write messages to a Kafka cluster",
   "type": "object",
+  "required": ["connection", "topic"],
   "properties": {
     "connection": {
       "title": "Connection details",
-      "description": "settings to stablish the connection to the kafka services",
+      "description": "Settings to establish the connection to the kafka service",
       "$ref": "./connection.json",
       "type": "object"
     },
     "producer": {
       "title": "Producer options",
-      "description": "details about how to write to a topic",
+      "description": "Details about how to write to a topic",
       "$ref": "./producer.json",
       "type": "object"
     },
     "topic": {
       "title": "Topic",
-      "description": "the topics to write to",
+      "description": "Topic to write to",
       "type": "string"
     },
     "key_meta": {
       "title": "Key Meta Name",
-      "description": "the name of the header where the kafka message key value is written",
+      "description": "Name of the header where the kafka message key value is written",
       "type": "string"
     }
   },