fix kafka test

examples/kafka-test/docs/asyncapi.md

@@ -0,0 +1,99 @@
+# Kafka test 1 documentation
+
+
+## Table of Contents
+
+* [Servers](#servers)
+  * [mykafka](#mykafka-server)
+
+## Servers
+
+### `mykafka` Server
+
+* URL: `kafka-secure://kafka://pkc-6ojv2.us-west4.gcp.confluent.cloud:9092/`
+* Protocol: `kafka-secure`
+
+
+#### Security
+
+##### Security Requirement 1
+
+* Type: `ScramSha256`
+  * security.protocol: SASL_SSL
+  * sasl.mechanism: SCRAM-SHA-256
+
+
+
+
+##### Security Requirement 2
+
+* Type: `ScramSha256`
+  * security.protocol: SASL_SSL
+  * sasl.mechanism: SCRAM-SHA-256
+
+
+
+
+
+
+
+## Operations
+
+### REQUEST `undefined` Operation
+
+*Publish messages to Test channel.*
+
+* Operation ID: `onTest`
+
+#### Message `testMessage`
+
+##### Payload
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| (root) | object | - | - | - | **additional properties are allowed** |
+| test | string | - | - | - | - |
+
+> Examples of payload _(generated)_
+
+```json
+{
+  "test": "string"
+}
+```
+
+
+#### Request information
+
+*  should be done to channel: ``
+#### Operation reply address information
+
+* Operation reply address location: `$message.header#/replyTo`
+
+
+
+### RECEIVE `undefined` Operation
+
+*Recieve messages from Produce channel.*
+
+* Operation ID: `onProduce`
+
+#### Message `produceMessage`
+
+##### Payload
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| (root) | object | - | - | - | **additional properties are allowed** |
+| test | string | - | - | - | - |
+
+> Examples of payload _(generated)_
+
+```json
+{
+  "test": "string"
+}
+```
+
+
+

src/adapters/kafka/index.ts

@@ -3,6 +3,12 @@ import Adapter from '../../lib/adapter.js'
 import GleeMessage from '../../lib/message.js'
 import { KafkaAdapterConfig, KafkaAuthConfig } from '../../lib/index.js'
 
+enum SECURITY_TYPES {
+  USER_PASSWORD = 'userPassword',
+  SCRAM_SHA_256 = 'scramSha256',
+  SCRAM_SHA_512 = 'scramSha512',
+}
+
 class KafkaAdapter extends Adapter {
   private kafka: Kafka
   private firstConnect = true