Registry / messaging / uber-go-kafka-client

uber-go-kafka-client

JSON →
library0.2.2gogounverified

A Go client library for Apache Kafka with support for producing and consuming messages.

messaging
go get github.com/uber-go/kafka-client
github ↗homepage ↗docs ↗
INSTALL
IMPORT
SIG · UBER-GO-KAFKA-CLIE
U
uber-go-kafka-client
messaginggov0.2.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
✓ github.com/uber-go/kafka-client

Create a Kafka producer.

package main import ( "context" "fmt" "github.com/uber-go/kafka-client/kafka" ) func main() { producer, _ := kafka.NewProducer(kafka.ProducerConfig{}) defer producer.Close() fmt.Println(producer) }
Debug
Known issues

No known issues recorded.

Upgrade
Version history
0.2.2latest on pkg.go.dev
Audit
Dependencies

No dependency data recorded yet.

Agent activity
23 hits · last 30 days
node
22
OpenAI (training)
1
Resources
githubhttps://github.com/uber-go/kafka-client ↗
homepagehttps://github.com/uber-go/kafka-client ↗
docshttps://pkg.go.dev/github.com/uber-go/kafka-client#section-documentation ↗
uber-go-kafka-client — go get uber-go-kafka-client · libregistry