{"repo":"ricardo-ch/go-kafka","free":true,"listed":false,"github":"https://github.com/ricardo-ch/go-kafka","clone":"git clone https://github.com/ricardo-ch/go-kafka.git","description":"go-kafka facilitates Kafka listener implementation with multiple choice of retry pattern and producer above sarama","language":"Go","stars":20,"topics":["go","kafka","sarama","consumer","golang-library","producer"],"license":"MIT","category":"data-pipelines","readme_excerpt":"GO-KAFKA Go-kafka provides an easy way to use kafka listeners and producers with only a few lines of code. The listener is able to consume from multiple topics, and will execute a separate handler for each topic. v4 breaking changes — see Migration Guide (v3 → v4) for full details and checklist: - Tracing : OpenTracing replaced by OpenTelemetry (OTel). W3C Trace Context ( traceparent , tracestate ) instead of Jaeger. Remove github.com/ricardo-ch/go-tracing - Producer.Produce now requires a context.Context as first argument: Produce(ctx, msg) - SetLogger , SetLogLevel , LowercaseLevelAttr removed — use slog.SetDefault() instead - ExponentialBackoffFunc is now nil by default (evaluated lazily using current DurationBeforeRetry / MaxBackoffDuration ) - MaxBackoffDuration default changed from 1m to 10m - New ForwardMaxBackoffDuration global variable (default: 30s) — retry/deadletter forwarding now retries on producer failure - New WithLogContextStorer option for context-aware structured logging Quick start Simple consumer Simple producer Features - Multi-topic consumer with per-topic handlers - Blocking retry with configurable count, backoff, and exponential backoff (KIP-580 with jitter) - Automatic forwarding to retry/deadletter topics with guaranteed delivery (retry on producer failure) - Error classification: retriable, unretriable, omitted - Topic collision detection ( ErrRetryTopicCollision , ErrDeadletterTopicCollision ) - Prometheus metrics for consumer and producer - OpenT","default_branch":null,"files":null,"tree":[],"storefront":"/r/ricardo-ch","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/ricardo-ch/go-kafka/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}