Registry / messaging / threedotslabs-watermill-kafka-v2

threedotslabs-watermill-kafka-v2

JSON →
library2.5.0gogounverified

Provides Kafka publisher and subscriber implementations for the Watermill messaging library.

messaging
go get github.com/ThreeDotsLabs/watermill-kafka/v2
github ↗homepage ↗docs ↗
INSTALL
IMPORT
SIG · THREEDOTSLABS-WATE
T
threedotslabs-watermill-kafka-v2
messaginggov2.5.0
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/ThreeDotsLabs/watermill-kafka/v2

Creates a new Kafka publisher.

package main import ( "fmt" "github.com/ThreeDotsLabs/watermill-kafka/v2" ) func main() { publisher, _ := kafka.NewPublisher(kafka.PublisherConfig{}, nil) fmt.Println(publisher) }
Debug
Known issues

No known issues recorded.

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

No dependency data recorded yet.

Agent activity
20 hits · last 30 days
node
18
OpenAI (training)
1
Resources
githubhttps://github.com/ThreeDotsLabs/watermill-kafka ↗
homepagehttps://github.com/ThreeDotsLabs/watermill-kafka ↗
docshttps://pkg.go.dev/github.com/ThreeDotsLabs/watermill-kafka/v2#section-documentation ↗
threedotslabs-watermill-kafka-v2 — go get threedotslabs-watermill-kafka-v2 · libregistry