#

sarama

Here are 81 public repositories matching this topic...

bsm / sarama-cluster

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

go kafka deprecated consumer sarama

Updated Jan 8, 2020
Go

jamiealquiza / sangrenel

Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"

go benchmark kafka load-testing sarama

Updated May 12, 2023
Go

lixd / kafka-go-example

kafka-go-example 以及系列教程

golang kafka sarama

Updated Aug 27, 2024
Go

ErikJiang / kafka_cluster_example

🪲 kafka cluster example

docker kafka cluster sarama

Updated Feb 15, 2019
Go

tal-tech / pan

Pan is a high performance mq proxy,support kafka,rabbit-mq,rocketmq,nsq and other mq

kafka rabbitmq nsq pan sarama mq rocketmq mqproxy

Updated Oct 9, 2020
Go

adamnoto / banku

Go event sourcing with Kafka, example project

go kafka event-sourcing sarama

Updated Aug 25, 2017
Go

wopehq / kafka-do

Higher level abstraction for franz-go.

kafka abstraction sarama

Updated Aug 22, 2022
Go

ricardo-ch / go-kafka

Go library for Apache Kafka consumers and producers, built on Sarama, with configurable retries, retry topics, and dead-letter handling.

go golang kafka consumer retry producer sarama dead-letter-queue

Updated Oct 30, 2026
Go

iimos / saramaprom

Metrics exporter from Sarama to Prometheus.

kafka metrics prometheus sarama

Updated Dec 30, 2023
Go

1046102779 / message_middleware

为了促进产品的平台化建设, 把kafka消息队列从服务中抽象出来。让消息队列只关注消息的订阅和发布，使用微服务，减少与业务逻辑的耦合, 该服务支持多实例部署

kafka sarama rpcx

Updated Jun 22, 2017
Go

tal-tech / triton

Triton is a high-performance mq consumer, support kafka,rabbit-mq,rocketmq,nsq and other mq

kafka rabbitmq triton nsq sarama rocketmq mq-consumer consumer-messages

Updated Feb 23, 2021
Go

Worldbug / kafeman

minimalistic CLI for kafka

go cli golang kafka tools protobuf sarama

Updated Mar 22, 2024
Go

smallnest / kafka_monitor

A kafka monitor to send alarm emails

monitor kafka lag sarama

Updated Feb 6, 2017
Go

arkady-emelyanov / kafkabeat

Elastic Beat that consumes Apache Kafka topics and ships events to Elasticsearch, Logstash or any Beats output. Plain and JSON codecs.

go golang elasticsearch logstash kafka logging beats kafka-consumer apache-kafka observability sarama data-pipeline log-shipper elastic-stack elk-stack elastic-beats

Updated Apr 29, 2019
Go

kafka-go

gocollection / kafka-go

make your kafka integration easy with kafka-go (supports Kafka v0.8 - v2.3)

pubsub consumer kafka-client sarama kafka-cluster pubsub-library minimal-efforts

Updated Aug 1, 2021
Go

flyaways / streaming

Streaming is a client library, where the input and output data are stored in Kafka clusters.

golang kafka stream sarama

Updated Dec 15, 2023
Go

cobolbaby / log-agent

🐶 Go实现生产级的日志收集器

hooks cassandra fsnotify debounce delayed-jobs bfs badger kafka-schema-registry watchdog sarama goroutine-pool ctime gocql kafka-avro go-plugin session-window

Updated Feb 23, 2023
Go

damiannolan / sasl

A simple and straight forward implementation of Shopify/sarama's AccessTokenProvider interface to be used for the SASL/OAUTHBEARER auth mechanism for Apache Kafka

oauth2 kafka sasl sarama oauthbearer

Updated May 21, 2024
Go

hatamiarash7 / Barmak

Benchmark of Kafka libraries for Go

go golang benchmarking benchmark kafka confluent kafka-benchmark sarama goka kafka-go

Updated Oct 27, 2026
Go

teng231 / kafclient

pubsub controller using kafka and base on sarama. Easy controll flow for actions streamming, event driven.

streaming kafka event-driven sarama

Updated Dec 28, 2023
Go

Add this topic to your repo

To associate your repository with the sarama topic, visit your repo's landing page and select "manage topics."