#

sarama

Here are 68 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-kafka facilitates Kafka listener implementation with multiple choice of retry pattern and producer above sarama

go kafka consumer golang-library producer sarama

Updated Jan 6, 2025
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

1046102779 / message_middleware

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

kafka sarama rpcx

Updated Jun 22, 2017
Go

iimos / saramaprom

Metrics exporter from Sarama to Prometheus.

kafka metrics prometheus sarama

Updated Dec 30, 2023
Go

smallnest / kafka_monitor

A kafka monitor to send alarm emails

monitor kafka lag sarama

Updated Feb 6, 2017
Go

Worldbug / kafeman

minimalistic CLI for kafka

go cli golang kafka tools protobuf sarama

Updated Mar 22, 2024
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 Jan 7, 2025
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

digorithm / event-driven-kafka-go-template

Simple template for event-driven systems using Go and Kafka.

golang kafka sarama

Updated Aug 24, 2020
Go

Improve this page

Add a description, image, and links to the sarama topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

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