admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 17:48:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: apply custom producer config for kafkaHealthCheck (#39283)

Browse Source 
issue: https://github.com/milvus-io/milvus/issues/39287
KafkaHealthCheck init without ProducerExtraConfig. This PR fix that.

---------

Signed-off-by: DLT1412 <tuduc93@gmail.com>
Co-authored-by: DucLT <duc.le1@be.com.vn>
This commit is contained in:
Duc Le Tu 2025-01-16 18:31:02 +07:00 committed by GitHub
parent 172051b050
commit 2a962ad1ec
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/mq/msgstream/msgstream_util.go
View File

@ -109,6 +109,11 @@ func PulsarHealthCheck(clusterStatus *pcommon.MQClusterStatus) {
// KafkaHealthCheck Perform a health check by retrieving cluster metadata // KafkaHealthCheck Perform a health check by retrieving cluster metadata
func KafkaHealthCheck(clusterStatus *pcommon.MQClusterStatus) { func KafkaHealthCheck(clusterStatus *pcommon.MQClusterStatus) {
config := kafkamqwrapper.GetBasicConfig(&paramtable.Get().KafkaCfg) config := kafkamqwrapper.GetBasicConfig(&paramtable.Get().KafkaCfg)
// Set extra config for producer
pConfig := (&paramtable.Get().KafkaCfg).ProducerExtraConfig.GetValue()
for k, v := range pConfig {
config.SetKey(k, v)
}
producer, err := kafka.NewProducer(&config) producer, err := kafka.NewProducer(&config)
if err != nil { if err != nil {
clusterStatus.Reason = fmt.Sprintf("failed to create Kafka producer: %v", err) clusterStatus.Reason = fmt.Sprintf("failed to create Kafka producer: %v", err)