Go로 만든 프로젝트에서 kafka 연동하여 로그를 수집하는데 confluent-kafka-go를 사용하고 있었다. package main import ( "fmt" "github.com/confluentinc/confluent-kafka-go/kafka" ) var kafkaClient *kafka.Producer func main() { kafkaClient, _ = kafka.NewProducer(&kafka.ConfigMap{ "bootstrap.servers": "broker:9092", "acks": 1, }) go func() { for e := range p.Events() { switch ev := e.(type) { case *kafka.Message: m := ev if m.TopicPartition.Error != nil { fmt.Printf("Delivery failed: %v,