{"id":51180,"library":"confluentinc-confluent-kafka-go","title":"Confluent Kafka Go","description":"A Go client for Apache Kafka, based on the Confluent Kafka client library (librdkafka).","status":"active","version":"1.9.2","language":"go","source_language":null,"source_url":"https://github.com/confluentinc/confluent-kafka-go","tags":["kafka","messaging","streaming"],"install":[{"cmd":"go get github.com/confluentinc/confluent-kafka-go","lang":"bash","label":"Install github.com/confluentinc/confluent-kafka-go"}],"dependencies":[],"imports":[{"symbol":"kafka","correct":"github.com/confluentinc/confluent-kafka-go/kafka"}],"quickstart":{"code":"package main\n\nimport (\n\t\"github.com/confluentinc/confluent-kafka-go/kafka\"\n)\n\nfunc main() {\n\tp, err := kafka.NewProducer(&kafka.ConfigMap{\"bootstrap.servers\": \"localhost\"})\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tp.Produce(&kafka.Message{TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny}, Value: []byte(\"hello\")}, nil)\n}","lang":"go","description":"Creates a Kafka producer and sends a message."},"warnings":[{"fix":"Install librdkafka via your package manager or use a Docker image with it pre-installed.","message":"Requires librdkafka to be installed on the system.","severity":"gotcha","affected_versions":">=0.0.0"}],"env_vars":null,"search_vec":"'apach':8 'base':10 'client':6,15 'confluent':1,13 'go':3,5 'kafka':2,9,14,18 'librari':16 'librdkafka':17 'messag':19 'stream':20","created_at":"2026-06-15T06:03:02.936472+00:00","updated_at":"2026-06-15T06:03:02.936472+00:00","problems":[],"ecosystem":"go","meta_description":null,"install_score":null,"quickstart_score":null,"quickstart_tag":null,"pypi_latest":null,"cli_name":null,"cli_version":null,"type":"library","homepage":"https://github.com/confluentinc/confluent-kafka-go","github":"https://github.com/confluentinc/confluent-kafka-go","docs":"https://pkg.go.dev/github.com/confluentinc/confluent-kafka-go#section-documentation","changelog":null,"pypi":null,"npm":null,"openapi_spec":null,"status_page":null,"smithery":null,"categories":["messaging"],"base_url":null,"auth_type":null,"provenance":{"verified_status":null,"verified_at":null,"last_verified":"2026-06-15","next_check":"2026-12-12","install_tag":null}}