[FEATURE REQUEST] support kafka set SASL Mechanism
Open
Nobody has claimed this yet.
enhancement
- Dominant language
- Go
- Stars
- 25
- Forks
- 103
- Avg merge
- 29m
- Merged PRs (30d)
- 2
Description
Why this feature?
aws msk 的SASL/SCRAM 身份验证 认证方式，需要设置SASL设置为SCRAM-SHA-512，可否在config增加该配置项？
Suggested Solution
在sarama.go中增加
if conf.Username != "" || conf.Password != "" {
kfk.Net.SASL.Enable = true
kfk.Net.SASL.User = conf.Username
kfk.Net.SASL.Password = conf.Password
# 增加
kfk.Net.SASL.Mechanism = conf.Mechanism
}
Additional Information
No response
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start in sarama.go at the existing Username and Password configuration path, then trace how the Kafka config is defined and populated. Add the requested mechanism configuration so AWS MSK SCRAM-SHA-512 can be selected, and verify that the configured value reaches the Kafka SASL settings.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- go, kafka
- Domain
- backend, distributed-systems
- Issue type
- Feature
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Quiet
- Clarity
- Mostly clear
- Newbie friendliness
- 58/100