blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-12-16 02:27:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add TLS config for kafka checker.

Browse Source
This commit is contained in:
Wang Zhi 2023-08-25 19:00:52 +08:00 committed by GitHub
parent e4d7693af2
commit 81443cb4c6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tools/component/component.go
View File

@ -39,6 +39,7 @@ import (
"gorm.io/gorm" "gorm.io/gorm"
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/config" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/config"
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/kafka"
"github.com/minio/minio-go/v7/pkg/credentials" "github.com/minio/minio-go/v7/pkg/credentials"
) )
@ -274,6 +275,7 @@ func checkKafka() error {
cfg.Net.SASL.User = config.Config.Kafka.Username cfg.Net.SASL.User = config.Config.Kafka.Username
cfg.Net.SASL.Password = config.Config.Kafka.Password cfg.Net.SASL.Password = config.Config.Kafka.Password
} }
kafka.SetupTLSConfig(cfg)
kafkaClient, err := sarama.NewClient(config.Config.Kafka.Addr, cfg) kafkaClient, err := sarama.NewClient(config.Config.Kafka.Addr, cfg)
if err != nil { if err != nil {
return errs.Wrap(err) return errs.Wrap(err)