Registry / messaging / confluentinc-confluent-kafka-go-v1

confluentinc-confluent-kafka-go-v1

JSON →
library1.8.2gogounverified

A Go client for Apache Kafka, providing high-level and low-level producer and consumer APIs.

messaging
go get gopkg.in/confluentinc/confluent-kafka-go.v1
github ↗homepage ↗docs ↗
INSTALL
IMPORT
SIG · CONFLUENTINC-CONFL
C
confluentinc-confluent-kafka-go-v1
messaginggov1.8.2
harness data pending
Install & Compatibility
Where this runs

No compatibility data collected yet for this library.

Code
Verified usage

Verified import paths — ran on the pinned version, not inferred.

kafka
✓ gopkg.in/confluentinc/confluent-kafka-go.v1

Create a Kafka producer and send messages.

package main import ( "fmt" "gopkg.in/confluentinc/confluent-kafka-go.v1/kafka" ) func main() { p, err := kafka.NewProducer(&kafka.ConfigMap{"bootstrap.servers": "localhost"}) if err != nil { panic(err) } defer p.Close() fmt.Println("Producer created") }
Debug
Known issues
breakingVersion 1.x uses the old API; v2 is available with breaking changes.
fix
Migrate to github.com/confluentinc/confluent-kafka-go/v2 for the latest API.
affects: >=1.0.0 <2.0.0
Upgrade
Version history
1.8.2latest on pkg.go.dev
Audit
Dependencies

No dependency data recorded yet.

Agent activity
38 hits · last 30 days
node
36
OpenAI (training)
1
Resources
githubhttps://github.com/confluentinc/confluent-kafka-go ↗
homepagehttps://github.com/confluentinc/confluent-kafka-go ↗
docshttps://pkg.go.dev/gopkg.in/confluentinc/confluent-kafka-go.v1#section-documentation ↗
confluentinc-confluent-kafka-go-v1 — go get confluentinc-confluent-kafka-go-v1 · libregistry