feat: kafka adapter (asyncapi#342)

Co-authored-by: Fran Mendez <fmvilas@gmail.com>

.gitignore

@@ -4,4 +4,4 @@ dist
 coverage
 .vscode
 .glee
-.next
+.next

docs/config-file.md

@@ -18,6 +18,7 @@ This function must return an object with the following shape:
 export default async function () {
   return {
     glee: {},
+    kafka: {},
     websocket: {},
     mqtt: {},
     cluster: {}
@@ -124,3 +125,15 @@ These configurations apply to Glee itself, rather than any specific protocol.
 |mqtt.authentication.userPassword| username and password parameters for authentication|
 |mqtt.authentication.userPassword.username| username parameter
 |mqtt.authentication.userPassword.password| password parameter
+
+### Kafka
+
+|Field|Description|
+|---|---|
+|kafka.authentication| Kafka authentication configuration|
+|kafka.authentication.key | Kafka Broker Key
+|kafka.authentication.cert| Client certificate
+|kafka.authentication.clientId| Kafka client Id for authentication
+|kafka.authentication.rejectUnauthorized | Boolean flag for accepting the valid SSL certificates
+|kafka.authentication.username| The username to use during authentication.
+|kafka.authentication.password| The password to use during authentication.

examples/dummy/.env

@@ -1 +1 @@
-GLEE_SERVER_CERTS=mosquitto:mosquitto.org.crt
+GLEE_SERVER_CERTS=mosquitto:mosquitto.org.crt

examples/kafka-test/.env

@@ -0,0 +1 @@
+GLEE_SERVER_NAMES=mykafka

examples/kafka-test/.gitignore

@@ -0,0 +1,4 @@
+node_modules
+.glee
+.vscode
+local.env

examples/kafka-test/README.md

@@ -0,0 +1,3 @@
+# Dummy
+
+This is a dummy example mainly used to test functionalities.

examples/kafka-test/asyncapi.yaml

@@ -0,0 +1,31 @@
+asyncapi: 2.4.0
+info:
+  title: Kafka test
+  version: '1'
+servers:
+  mykafka:
+    url: kafka://pkc-6ojv2.us-west4.gcp.confluent.cloud:9092
+    protocol: kafka-secure
+    security:
+      - saslScramExample: []
+channels:
+  test:
+    publish:
+      operationId: onTest
+      message:
+        $ref: '#/components/messages/testMessage'
+  produce:
+    subscribe:
+      message:
+        $ref: '#/components/messages/testMessage'
+components:
+  messages:
+    testMessage:
+      payload:
+        type: object
+        properties:
+          test:
+            type: string 
+  securitySchemes:
+      saslScramExample:
+        type: scramSha256

examples/kafka-test/functions/onTest.ts

@@ -0,0 +1,10 @@
+export default async function (event) {
+  return {
+    send: [{
+      server: event.serverName,
+      channel: 'produce',
+      payload: event.payload,
+      headers: event.headers,
+    }]
+  }
+}

examples/kafka-test/glee.config.js

@@ -0,0 +1,9 @@
+export default async function () {
+  return {
+    kafkaOptions: {
+      authentication: {
+        key: 'XIL3PSQNLE3ROP7A',
+      }
+    }
+  }
+}