Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FEATURE REQUEST] support kafka set SASL Mechanism #141

Open
John-Funcity opened this issue Oct 17, 2024 · 0 comments
Open

[FEATURE REQUEST] support kafka set SASL Mechanism #141

John-Funcity opened this issue Oct 17, 2024 · 0 comments
Labels
enhancement New feature or request

Comments

@John-Funcity
Copy link

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

@John-Funcity John-Funcity added the enhancement New feature or request label Oct 17, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

1 participant