feat(kafka-logger): support sasl conf

apisix/plugins/kafka-logger.lua

@@ -51,6 +51,16 @@ local schema = {
                 },
             },
         },
+        sasl_config = {
+            type = "object",
+            description = "sasl config",
+            properties = {
+                mechanism = { type = "string", description = "mechanism" },
+                password =  { type = "string", description = "password" },
+                user = { type = "string", description = "user" },
+                strategy = { type = "string", description = "strategy" }
+            }
+        },
         kafka_topic = {type = "string"},
         producer_type = {
             type = "string",
@@ -205,7 +215,8 @@ function _M.log(conf, ctx)
     for host, port in pairs(conf.broker_list) do
         local broker = {
             host = host,
-            port = port
+            port = port,
+            sasl_config = conf.sasl_config or nil
         }
         core.table.insert(broker_list, broker)
     end

docs/en/latest/plugins/kafka-logger.md

@@ -38,6 +38,11 @@ It might take some time to receive the log data. It will be automatically sent a
 | Name                   | Type    | Required | Default        | Valid values          | Description                                                                                                                                                                                                                                                                                                                                      |
 | ---------------------- | ------- | -------- | -------------- | --------------------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ |
 | broker_list            | object  | True     |                |                       | List of Kafka brokers (nodes).                                                                                                                                                                                                                                                                                                                   |
+| sasl_config            | object  | False    |                |                       | Kafka sasl conf.                                                                                                                                                                                                                                                                                                                   |
+| sasl_config.mechanism  | string  | False    |                |                       | Kafka mechanism.                                                                                                                                                                                                                                                                                                                   |
+| sasl_config.password   | string  | False    |                |                       | Kafka password.                                                                                                                                                                                                                                                                                                                   |
+| sasl_config.user       | string  | False    |                |                       | Kafka user.                                                                                                                                                                                                                                                                                                                       |
+| sasl_config.strategy   | string  | False    |                |                       | Kafka strategy.                                                                                                                                                                                                                                                                                                                   |
 | kafka_topic            | string  | True     |                |                       | Target topic to push the logs for organisation.                                                                                                                                                                                                                                                                                                  |
 | producer_type          | string  | False    | async          | ["async", "sync"]     | Message sending mode of the producer.                                                                                                                                                                                                                                                                                                            |
 | required_acks          | integer | False    | 1              | [0, 1, -1]            | Number of acknowledgements the leader needs to receive for the producer to consider the request complete. This controls the durability of the sent records. The attribute follows the same configuration as the Kafka `acks` attribute. See [Apache Kafka documentation](https://kafka.apache.org/documentation/#producerconfigs_acks) for more. |