Skip to content

feat: As a user, I want to support sasl_config in kafka-logger plugin, so that we can send logs to brokers that enable authentication #8046

Description

@starsz

Description

Hello,

Now I found "lua-resty-kafka" lib had supported set sasl_config in the client.
docs: https://github.com/doujiang24/lua-resty-kafka#new

So I want to support set sasl_config in kafka-logger plugin, then we can send logs to brokers that enable authentication.
Like:

{
    "kafka-logger":{
        "brokers":[
            {
                "host":"127.0.0.1",
                "port":9092,
                "sasl_config":{
                    "mechanism":"PLAIN",
                    "user":"USERNAME",
                    "password":"PASSWORD"
                }
            }
        ],
        "kafka_topic":"test2",
        "key":"key1",
        "batch_max_size":1,
        "name":"kafka logger"
    }
}

Metadata

Metadata

Assignees

Labels

enhancementNew feature or request

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions