feat: adapt Kafka bindings to v3

Signed-off-by: Laurent Broudoux <[email protected]>
asyncapi · Nov 10, 2023 · 5030531 · 5030531
1 parent 18ccc41
commit 5030531
Show file tree

Hide file tree

Showing 4 changed files with 46 additions and 20 deletions.
diff --git a/definitions/3.0.0/channelBindingsObject.json b/definitions/3.0.0/channelBindingsObject.json
@@ -84,7 +84,7 @@
     "kafka": {
       "properties": {
         "bindingVersion": {
-          "enum": ["0.4.0", "0.3.0"]
+          "enum": ["v3-0.4.0", "0.4.0", "0.3.0"]
         }
       },
       "allOf": [
@@ -98,7 +98,20 @@
             }
           },
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/channel.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/channel.json"
+          }
+        },
+        {
+          "if": {
+            "required": [ "bindingVersion" ],
+            "properties": {
+              "bindingVersion": {
+                "const": "v3-0.4.0"
+              }
+            }
+          }, 
+          "then": {
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/channel.json"
           }
         },
         {

diff --git a/definitions/3.0.0/messageBindingsObject.json b/definitions/3.0.0/messageBindingsObject.json
@@ -118,7 +118,7 @@
     "kafka": {
       "properties": {
         "bindingVersion": {
-          "enum": ["0.4.0", "0.3.0", "0.1.0"]
+          "enum": ["v3-0.4.0", "0.4.0", "0.3.0"]
         }
       },
       "allOf": [
@@ -132,46 +132,46 @@
             }
           },
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/message.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/message.json"
           }
         },
         {
           "if": {
             "required": [ "bindingVersion" ],
             "properties": {
               "bindingVersion": {
-                "const": "0.4.0"
+                "const": "v3-0.4.0"
               }
             }
           }, 
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/message.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/message.json"
           }
         },
         {
           "if": {
             "required": [ "bindingVersion" ],
             "properties": {
               "bindingVersion": {
-                "const": "0.3.0"
+                "const": "0.4.0"
               }
             }
           }, 
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.3.0/message.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/message.json"
           }
         },
         {
           "if": {
             "required": [ "bindingVersion" ],
             "properties": {
               "bindingVersion": {
-                "const": "0.1.0"
+                "const": "0.3.0"
               }
             }
           }, 
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.1.0/message.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/0.3.0/message.json"
           }
         }
       ]

diff --git a/definitions/3.0.0/operationBindingsObject.json b/definitions/3.0.0/operationBindingsObject.json
@@ -118,7 +118,7 @@
     "kafka": {
       "properties": {
         "bindingVersion": {
-          "enum": ["0.4.0", "0.3.0", "0.1.0"]
+          "enum": ["v3-0.4.0", "0.4.0", "0.3.0"]
         }
       },
       "allOf": [
@@ -132,46 +132,46 @@
             }
           },
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/operation.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/operation.json"
           }
         },
         {
           "if": {
             "required": [ "bindingVersion" ],
             "properties": {
               "bindingVersion": {
-                "const": "0.4.0"
+                "const": "v3-0.4.0"
               }
             }
           }, 
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/operation.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/operation.json"
           }
         },
         {
           "if": {
             "required": [ "bindingVersion" ],
             "properties": {
               "bindingVersion": {
-                "const": "0.3.0"
+                "const": "0.4.0"
               }
             }
           }, 
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.3.0/operation.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/operation.json"
           }
         },
         {
           "if": {
             "required": [ "bindingVersion" ],
             "properties": {
               "bindingVersion": {
-                "const": "0.1.0"
+                "const": "0.3.0"
               }
             }
           }, 
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.1.0/operation.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/0.3.0/operation.json"
           }
         }
       ]

diff --git a/definitions/3.0.0/serverBindingsObject.json b/definitions/3.0.0/serverBindingsObject.json
@@ -84,7 +84,7 @@
     "kafka": {
       "properties": {
         "bindingVersion": {
-          "enum": ["0.4.0", "0.3.0"]
+          "enum": ["v3-0.4.0", "0.4.0", "0.3.0"]
         }
       },
       "allOf": [
@@ -98,7 +98,20 @@
             }
           },
           "then": {
-            "$ref": "http://asyncapi.com/bindings/kafka/0.4.0/server.json"
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/server.json"
+          }
+        },
+        {
+          "if": {
+            "required": [ "bindingVersion" ],
+            "properties": {
+              "bindingVersion": {
+                "const": "v3-0.4.0"
+              }
+            }
+          }, 
+          "then": {
+            "$ref": "http://asyncapi.com/bindings/kafka/v3-0.4.0/server.json"
           }
         },
         {