From 6905e40c2774c54b49394e39162d2094f4b841ee Mon Sep 17 00:00:00 2001
From: Carson Ip <carson.ip@elastic.co>
Date: Mon, 10 Nov 2025 15:28:38 +0000
Subject: [PATCH] Fix OnBrokerConnect log field conflict

---
 kafka/logger.go | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/kafka/logger.go b/kafka/logger.go
index 65caefbc..60e75938 100644
--- a/kafka/logger.go
+++ b/kafka/logger.go
@@ -39,9 +39,11 @@ func (l *loggerHook) OnBrokerConnect(meta kgo.BrokerMetadata, dialDur time.Durat
 	if err != nil {
 		fields := []zap.Field{
 			zap.Error(err),
-			zap.Duration("event.duration", dialDur),
-			zap.String("host", meta.Host),
-			zap.Int32("port", meta.Port),
+			zap.Int64("event.duration", dialDur.Nanoseconds()),
+			zap.String("destination.domain", meta.Host),
+			zap.Int32("destination.port", meta.Port),
+			zap.Int32("node_id", meta.NodeID),
+			zap.Stringp("rack", meta.Rack),
 			zap.Stack("stack"),
 		}
 		if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {