milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: correct a minor typo in log message of kafka client (#41216) 

fixes a minor typo that notify users that some special kafka configs are
overwritten in Milvus.

Signed-off-by: lambert <lambert@daangn.com>
pull/41369/head
Sungyun Hur 2025-04-16 22:14:20 +09:00 committed by GitHub
parent 5fd8a196f6
commit fbd595eae1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go
View File

@ -256,7 +256,7 @@ func (kc *kafkaClient) StringToMsgID(id string) (common.MessageID, error) {
func (kc *kafkaClient) specialExtraConfig(current *kafka.ConfigMap, special kafka.ConfigMap) {
for k, v := range special {
if existingConf, _ := current.Get(k, nil); existingConf != nil {
log.Warn(fmt.Sprintf("The existing config : %v=%v will be covered by the speciled kafka config : %v.", k, v, existingConf))
log.Warn(fmt.Sprintf("The existing config : %v=%v will be covered by the special kafka config : %v.", k, v, existingConf))
}
current.SetKey(k, v)