我需要 kafka 消費者日志進行除錯。我執行以下操作：
chanLogs := make(chan confluentkafka.LogEvent)
go func() {
for {
logEv := <-chanLogs
logger.Debug("KAFKA: " logEv.String())
}
}()
configMap["go.logs.channel.enable"] = true
configMap["go.logs.channel"] = chanLogs
consumer, err := confluentkafka.NewConsumer(&configMap)
err := consumer.SubscribeTopics(Topics, nil)
我從來沒有得到一條線。我用 kafka chan ( consumer.Logs())嘗試過，結果相同。我做錯了什么？
UPD
在最初的帖子中，我錯誤地設定了引數名稱。正確的是go.logs.channel.enable. 但有時這仍然不起作用。
uj5u.com熱心網友回復：
如檔案中所述，您應該啟用該功能：
go.logs.channel.enable (bool, false) - Forward log to Logs() channel.
go.logs.channel (chan kafka.LogEvent, nil) - Forward logs to application-provided channel instead of Logs(). Requires go.logs.channel.enable=true.
所以改變你的代碼，如：
configMap["go.logs.channel"] = chanLogs
configMap["go.logs.channel.enable"] = true
consumer, err := confluentkafka.NewConsumer(&configMap)
另請參閱此處的檔案或代碼存盤庫中的示例
uj5u.com熱心網友回復：
解決方案是添加
configMap["debug"] = "all"
我在這里找到了
轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/364097.html