Sarama is a Go library for Apache Kafka 0.8, and up.

sarama Sarama is an MIT-licensed Go client library for Apache Kafka version 0.8 (and later). Getting started API documentation and examples are available via godoc. Mocks for testing are available in the mock
Category: Golang / Messaging
Watchers: 665
Star: 9.6k
Fork: 1.6k
Last update: Jan 23, 2023

Related Repos

Buzz2d0 pingser Use pingser to create client and server based on ICMP Protocol to send and receive custom message content. examples source code: ./examples Us

sinamna Chiz Broker: a broker for fun ChizBroker is a fast and simple GRPC based implementation of kafka. Features: Ready to be deployed on kubernetes Prometh

shaswata56 A high-level RabbitMQ driver for Golang.

NishanthSpShetty Lignum is a distributed message queue, implementing something like kafka in go using Consul as cluster management service.

rabbitmq An AMQP 0-9-1 Go client maintained by the RabbitMQ team.

OpenIMSDK Instant messaging server. Backend in pure Golang, wire transport protocol is JSON over websocket.

kha7iq PingMe is a personal project to satisfy my needs of having alerts, most major platforms have integration to send alerts but its not always useful, either you are stuck with one particular platform, or you have to do alot of integrations.

queer 신경 신경 /ɕʰinɡjʌ̹ŋ/ • sin-gyeong (try it with IPA Reader) nerve Nerve /nərv/ • noun (in the body) a whitish fiber or bundle of fibers that transmits imp

hoorayman a distributed chat system which can be used as chat rooms or state synchronization

dominikbraun buneary, pronounced bun-ear-y, is an easy-to-use RabbitMQ command line client for managing exchanges, managing queues and publishing messages to exchanges.

c16a Hermes Hermes is a tiny MQTT compatible broker written in Go. The goals of the project are as below Easy to compile, and run Tiny footprint Extensible

mostafa This is a k6 extension using the xk6 system.

mattermost It's written in Golang and React and runs as a single Linux binary with MySQL or PostgreSQL.

batchcorp RabbitMQ wrapper for steadway/amqp that supports auto-reconnects

vmihailenco[Go] MessagePack encoding for Golang