Address feedback

Author: k-raina

CHANGELOG.md

@@ -1,5 +1,17 @@
 # Confluent's Golang client for Apache Kafka
 
+## v2.12.0
+
+This is a feature release:
+
+confluent-kafka-go is based on librdkafka v2.12.0, see the
+[librdkafka v2.12.0 release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.12.0)
+for a complete list of changes, enhancements, fixes and upgrade considerations.
+
+### Enhancements
+
+* Add support for forwarding librdkafka log events to a Go channel in AdminClient (#1448)
+
 ## v2.11.0
 
 This is a feature release:
@@ -8,7 +20,6 @@ confluent-kafka-go is based on librdkafka v2.11.0, see the
 [librdkafka v2.11.0 release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.11.0)
 for a complete list of changes, enhancements, fixes and upgrade considerations.
 
-
 ## v2.10.1
 
 This is a maintenance release:

kafka/adminapi.go

@@ -3796,3 +3796,8 @@ func NewAdminClientFromConsumer(c *Consumer) (a *AdminClient, err error) {
 	a.isClosed = 0
 	return a, nil
 }
+
+// Logs returns the log channel if enabled, or nil otherwise.
+func (a *AdminClient) Logs() chan LogEvent {
+	return a.handle.logs
+}

kafka/adminapi_test.go

@@ -1355,6 +1355,75 @@ func TestAdminClientLog(t *testing.T) {
 		close(logsChan)
 	}()
 
+	// Verify that Logs() method returns the correct channel
+	if admin.Logs() != logsChan {
+		t.Fatalf("Expected admin.Logs() %v == logsChan %v", admin.Logs(), logsChan)
+	}
+
+	expectedLogs := map[struct {
+		tag     string
+		message string
+	}]bool{
+		{"INIT", "librdkafka"}: false,
+	}
+
+	go func() {
+		for {
+			select {
+			case log, ok := <-logsChan:
+				if !ok {
+					return
+				}
+
+				t.Log(log.String())
+
+				for expectedLog, found := range expectedLogs {
+					if found {
+						continue
+					}
+					if log.Tag != expectedLog.tag {
+						continue
+					}
+					if strings.Contains(log.Message, expectedLog.message) {
+						expectedLogs[expectedLog] = true
+					}
+				}
+			}
+		}
+	}()
+
+	<-time.After(time.Second * 5)
+
+	for expectedLog, found := range expectedLogs {
+		if !found {
+			t.Errorf(
+				"Expected to find log with tag `%s' and message containing `%s',"+
+				" but didn't find any.",
+				expectedLog.tag,
+				expectedLog.message)
+		}
+	}
+}
+
+func TestAdminClientLogWithoutChannel(t *testing.T) {
+	admin, err := NewAdminClient(&ConfigMap{
+		"debug":                  "all",
+		"bootstrap.servers":      "localhost:65533", // Unreachable to generate logs
+		"go.logs.channel.enable": true,
+		// Note: no "go.logs.channel" specified
+	})
+	if err != nil {
+		t.Fatalf("Failed to create AdminClient: %v", err)
+	}
+
+	defer admin.Close()
+
+	// Verify that Logs() method returns a channel when enabled but no channel provided
+	logsChan := admin.Logs()
+	if logsChan == nil {
+		t.Fatalf("Expected admin.Logs() to return a channel, got nil")
+	}
+
 	expectedLogs := map[struct {
 		tag     string
 		message string