Registry / messaging / bsm-sarama-cluster

bsm-sarama-cluster

JSON →

library2.1.15+incompatiblegogounverified

Cluster extensions for Sarama, enabling balanced consumption of Kafka topics across multiple nodes.

messaging

go get github.com/bsm/sarama-cluster

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · BSM-SARAMA-CLUSTER

bsm-sarama-cluster

messaginggov2.1.15+incompatible

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.

cluster

✓ github.com/bsm/sarama-cluster

Creates a cluster consumer and prints messages from a Kafka topic.

package main import ( "fmt" "github.com/bsm/sarama-cluster" ) func main() { config := cluster.NewConfig() consumer, _ := cluster.NewConsumer([]string{"localhost:9092"}, "group-id", []string{"topic"}, config) for msg := range consumer.Messages() { fmt.Println(string(msg.Value)) } }

Debug

Known issues

gotchaThis package is deprecated in favor of Sarama's built-in consumer group support.

fix

Use github.com/Shopify/sarama with ConsumerGroup instead.

affects: >=2.1.15

Upgrade

Version history

2.1.15+incompatiblelatest on pkg.go.dev

Audit

Dependencies

No dependency data recorded yet.

Agent activity

13 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/bsm/sarama-cluster ↗

homepagehttps://github.com/bsm/sarama-cluster ↗

docshttps://pkg.go.dev/github.com/bsm/sarama-cluster#section-documentation ↗