Kafka - Go related links and libraries The main purpose is reading / learning / teaching.
- Making Badass Developers - Kathy Sierra (Serious Pony) - https://www.youtube.com/watch?v=FKTxC9pl-WM
It isn’t about what skills you have but how quickly you learn.
$ make run
$ make crawl
- adxhyt/kafka-zookeeper-monitor - yet another kafka monitor by zookeeper
( 2015-11-12 / 9 commits / 0 stars ) - allmad/madq - [WIP] A high performance message queue, inspired by kafka
( 2016-07-11 / 78 commits / 3 stars ) - andreas-schroeder/kafka-health-check - Health Check for Kafka Brokers.
( 2016-10-26 / 63 commits / 8 stars ) - ansrivas/fwatcher - An application to watch a given directory for new files, read it and publish to Kafka ( using actors )
( 2017-03-19 / 35 commits / 0 stars ) - anthonyserious/go-kafka-test - Test building mircoservices with go and kafka
( 2017-02-23 / 7 commits / 0 stars ) - banno/terraform-provider-mesoskafka - Terraform Provider for the Mesos Kafka Scheduler API
( 2017-03-20 / 59 commits / 2 stars ) - brxie/kafka-gtk - GUI application for exchanging messages from Apache Kafka clusters
( 2016-12-02 / 18 commits / 0 stars ) - bsm/sarama-cluster - ---
( 2017-03-14 / 166 commits / 57 stars ) - cafxx/kafkabalancer - Automatically rebalance your kafka topics, partitions, replicas across your cluster
( 2016-10-06 / 47 commits / 0 stars ) - chenziliang/descartes.legacy - Data collecting infrastructure based on Kafka and Splunk
( 2015-05-13 / 40 commits / 0 stars ) - confluentinc/confluent-kafka-go - Confluent's Apache Kafka Golang client
( 2017-03-03 / 107 commits / 25 stars ) - corybuecker/kafka-testing - A Docker-based set of programs to send and receive messages through a Kafka cluster.
( 2016-09-10 / 7 commits / 0 stars ) - ctrlaltdel121/kafkacat-hk - Kafkacat wrapper for Heroku Kafka
( 2017-02-11 / 6 commits / 0 stars ) - datamountaineer/schema-registry - A CLI and Go client for Confluent's Kafka Schema Registry
( 2017-01-15 / 34 commits / 2 stars ) - dnance/lab-reservation - sample kafka consumers and producers
( 2016-10-20 / 7 commits / 0 stars ) - elodina/go-kafka - Quick up and running using Go for Apache Kafka
( 2015-04-21 / 64 commits / 6 stars ) - elodina/go-kafka-avro - go-kafka-avro implements Avro encoding and decoding compatible with Confluent Schema Registry.
( 2016-04-22 / 20 commits / 6 stars ) - elodina/go_kafka_client - Apache Kafka Client Library for Go
( 2016-05-13 / 859 commits / 65 stars ) - elodina/siesta - Making support for Apache Kafka in Go better
( 2016-04-25 / 196 commits / 14 stars ) - esdb/kafka-agent - Persist to local durable storage before sending to kafka, solve the logging problem once for all
( 2016-03-10 / 8 commits / 2 stars ) - fgeller/kt - Kafka command line tool
( 2017-03-22 / 176 commits / 15 stars ) - financial-times/coco-kafka-bridge - Kafka consumer forwarding messages to an HTTP endpoint.
( 2017-01-19 / 248 commits / 0 stars ) - financial-times/kafka-lagcheck - Kafka Consumer Lag Checking
( 2016-10-27 / 46 commits / 0 stars ) - financial-times/kafkaduct - Kafka HTTP to local kafka
( 2016-07-12 / 28 commits / 0 stars ) - financial-times/kmt-kafka-sync - A µService to listen for whitelisted events on Kafka and post them to Kinesis for processing via Lambda
( 2016-10-20 / 57 commits / 0 stars ) - financial-times/message-queue-go-producer - Kafka Proxy go producer library - responsible for writing messages to kafka, through the kafka proxy.
( 2017-03-20 / 28 commits / 0 stars ) - foxcomm/metamorphosis - The simple Kafka client in GoLang! Read and transform messages with ease.
( 2017-02-27 / 18 commits / 0 stars ) - funkygao/dbus - yet another databus that transfer/transform pipeline data between plugins
( 2017-03-22 / 458 commits / 0 stars ) - funkygao/gafka - A full ecosystem that is built around kafka powered by golang
( 2017-03-20 / 3,721 commits / 8 stars ) - garo/logs2kafka - Simple tool to listen incoming json based log events on TCP socket and forward them to Kafka
( 2016-12-05 / 19 commits / 2 stars ) - germanramos/kafka-console-consumer - ---
( 2016-09-05 / 18 commits / 0 stars ) - germanramos/kafka-console-producer - ---
( 2016-11-30 / 19 commits / 0 stars ) - gfremex/logrus-kafka-hook - A logrus.Hook which sends a single log entry to multiple kafka topics simultaneously.
( 2016-03-29 / 1 commits / 1 stars ) - gleicon/kafka-shell - golang shell utilities for kafka
( 2017-02-02 / 2 commits / 0 stars ) - go-kafka/connect - CLI tool and Go client library for the Kafka Connect REST API
( 2016-08-11 / 49 commits / 0 stars ) - go-wave/ykafka - ykafka is kafka repro for use low api read kafka and save offset
( 2016-12-29 / 4 commits / 2 stars ) - h12w/kafkaq - A Simple Message & Job Queue Based on Kafka
( 2015-08-07 / 4 commits / 0 stars ) - h12w/kpax - A modular & idiomatic Kafka client in Go
( 2016-09-06 / 268 commits / 2 stars ) - hellofresh/kandalf - RabbitMQ to Kafka bridge
( 2017-01-02 / 57 commits / 0 stars ) - hieutrtr/imaginary-backup-consumer - backup data by consume message from kafka
( 2017-03-21 / 26 commits / 0 stars ) - ian-kent/ktail - Tail a Kafka topic (see https://github.com/ian-kent/ktee)
( 2015-10-23 / 1 commits / 0 stars ) - ian-kent/ktee - Tee to a Kafka topic (see https://github.com/ian-kent/ktail)
( 2015-09-25 / 4 commits / 0 stars ) - jaehue/anyq - Queue library wrapper for widely popular queues - RabitMQ, Kafka, NSQ, NATS
( 2016-10-16 / 77 commits / 5 stars ) - jamiealquiza/sangrenel - Apache Kafka load testing: "...basically a cloth bag filled with small jagged pieces of scrap iron"
( 2016-12-15 / 87 commits / 23 stars ) - jbanier/passeplat - small go thingy that shift data around, from syslog to kafka is the first step.
( 2017-03-21 / 9 commits / 0 stars ) - jdamick/kafka - Producer and Consumer for Kafka in Go
( 2017-01-24 / 76 commits / 31 stars ) - jeffail/benthos - A persistent stream buffer
( 2017-01-03 / 119 commits / 3 stars ) - jeffallen/kboing - A load generator for Kafka
( 2016-06-14 / 4 commits / 0 stars ) - jhaynie/github-webhook-kafka - Github Webhook -> Kafka server
( 2016-10-17 / 10 commits / 0 stars ) - jianchen2580/log-stream - streaming kafka logs
( 2016-12-14 / 5 commits / 0 stars ) - jurriaan/kafkatools - CLI tools for monitoring and managing Apache Kafka
( 2017-02-04 / 39 commits / 1 stars ) - kasey/camus - what comes after kafka?
( 2015-10-08 / 2 commits / 0 stars ) - kchristidis/kafka-orderer - The prototype of what later became the Kafka-based ordering service for Hyperledger Fabric. (This repo is no longer maintained; kept for historical reasons.) Please see: https://github.com/hyperledger/fabric/tree/master/orderer
( 2016-10-09 / 69 commits / 5 stars ) - kochava/firehose - A Kafka topic transfer agent
( 2016-11-22 / 77 commits / 0 stars ) - krallistic/kafka-operator - [WIP] A Kafka Operator for Kubernetes
( 2017-03-24 / 58 commits / 0 stars ) - l0vest0rm/connpool - connection pool for go/golang to connect with redis/kafka/hbase/mysql and anything else
( 2017-03-08 / 8 commits / 1 stars ) - lancewf/sarama - Example using the sarama with kafka to add and retrieve messages from the stream
( 2017-02-16 / 1 commits / 0 stars ) - landoop/kafka-connectors-tests - Test suite for Kafka Connect connectors based on Landoop's Coyote and docker.
( 2017-03-10 / 83 commits / 0 stars ) - legionus/kafka-replicator - Kafka messages replicator
( 2015-11-19 / 12 commits / 0 stars ) - linkedin/burrow - Kafka Consumer Lag Checking
( 2017-03-07 / 160 commits / 209 stars ) - mailgun/kafka-pixy - gRPC/REST proxy for Kafka
( 2017-03-23 / 325 commits / 18 stars ) - majidgolshadi/kafka-consumer - Self balancing kafka consumer
( 2017-01-07 / 18 commits / 0 stars ) - marekgalovic/kafka-mysql - Kafka to mysql importer
( 2017-01-24 / 6 commits / 0 stars ) - marianogappa/bookie - Indexing for Kafka queues.
( 2017-03-24 / 58 commits / 1 stars ) - marianogappa/flowbro - Real-time flowchart visualisation for Kafka-based distributed systems.
( 2017-02-19 / 176 commits / 4 stars ) - matthias-margush/cdrt-kafka-go - CDRTs in Go, over Kafka
( 2017-01-22 / 1 commits / 0 stars ) - mediamath/kafka-proxy - A golang library for working with the Confluent Kafka Restful proxy
( 2016-09-13 / 7 commits / 0 stars ) - mediamath/sr - Publish schemas to confluent schema-registry
( 2017-02-23 / 14 commits / 3 stars ) - meitu/go-consumergroup - golang kafka consumer group
( 2017-01-19 / 12 commits / 3 stars ) - meteogroup/amqp-to-kafka - Fetches messages from AMQP and forwards them to Kafka
( 2017-03-10 / 15 commits / 0 stars ) - meteogroup/sqs-to-kafka - Fetches messages from SQS and forwards them to Kafka
( 2017-03-09 / 51 commits / 0 stars ) - mhausenblas/dnpipes - Distributed Named Pipes
( 2016-12-14 / 18 commits / 9 stars ) - mkocikowski/hbuf - User friendly implementation of ideas behind Kafka
( 2017-03-05 / 11 commits / 0 stars ) - moemoe89/simple-avro-kafka-golang - Simple Avro Kafka using Golang for Producer and Consumer
( 2016-09-28 / 1 commits / 0 stars ) - moemoe89/simple-kafka-golang - Simple Kafka using Golang for Producer and Consumer
( 2016-09-28 / 4 commits / 0 stars ) - moul/kafka-gateway - 🌊 Kafka Gateway (gRPC/protobuf + http/json)
( 2017-01-11 / 24 commits / 2 stars ) - movio/go-kafka - Assorted Golang Kafka utils
( 2016-10-31 / 5 commits / 0 stars ) - movio/kasper - Kasper is a Go library for Kafka stream processing
( 2017-03-16 / 262 commits / 0 stars ) - msales/kage - Kafka metrics agent.
( 2017-03-22 / 34 commits / 3 stars ) - mudit2108/docker-kafka - Apache Kafka cluster implemented with Docker
( 2016-12-07 / 10 commits / 0 stars ) - myself659/chanbroker - ChanBroker, a Broker for goroutine, is simliar to kafka
( 2017-03-08 / 11 commits / 1 stars ) - nesze/kafka-bridge - Kafka consumer publishing the messages to an HTTP endpoint.
( 2015-06-18 / 35 commits / 0 stars ) - nickbruun/gokafkagroupconsumer - Kafka 0.9+ group consumer for Go based on Shopify's sarama library
( 2016-01-26 / 1 commits / 0 stars ) - ninibe/netlog - A lightweight, HTTP-centric, log-based (Kafka-style) message queue. [WIP]
( 2016-09-22 / 53 commits / 11 stars ) - ombits/kafkaproducer - ---
( 2016-12-30 / 2 commits / 0 stars ) - onsdigital/dp-csv-splitter - A simple large CSV file splitter that creates Kafka messages from them
( 2017-03-16 / 107 commits / 0 stars ) - optiopay/kafka - Go driver for Kafka
( 2017-01-27 / 265 commits / 34 stars ) - orbat/krater - An io.Writer / io.ReaderFrom that produces to Kafka
( 2016-03-01 / 24 commits / 1 stars ) - philipjkim/kafka-brokers-go - Go library to access Kafka broker list in Zookeeper
( 2017-01-13 / 3 commits / 0 stars ) - philipjkim/kafka-sample-go - Kafka pub/sub sample in Go
( 2017-02-02 / 2 commits / 0 stars ) - pmdcosta/apache-kafka - Docker containers for an Apache Kafka cluster
( 2016-02-19 / 13 commits / 0 stars ) - pryz/kafka-training - Kafka training with Docker
( 2017-01-24 / 21 commits / 1 stars ) - rafaeljesus/event-srv - An event aggregation service for microservices ⌛
( 2017-03-19 / 25 commits / 1 stars ) - rafaeljesus/kafka-event-bus - A tiny wrapper around https://github.com/Shopify/sarama topic and consumer 🚌
( 2017-02-06 / 2 commits / 1 stars ) - randrr/kafka-example - An example on how to use Kafka with Golang.
( 2017-01-25 / 10 commits / 0 stars ) - redborder/dynamic-sensors-watcher - Service for allowing new sensors IP by watching a serial number netflow option template
( 2017-03-16 / 62 commits / 0 stars ) - redborder/k2http - Forwards messages from kafka to an HTTP endpoint.
( 2016-10-10 / 90 commits / 2 stars ) - roblaszczak/clikafka - Simple CLI tool for Kafka written in GO (Golang)
( 2017-02-23 / 4 commits / 0 stars ) - roblaszczak/gotify - Notifications framework
( 2017-02-16 / 5 commits / 0 stars ) - rollulus/kafcat - Tool for Kafka
( 2016-07-26 / 16 commits / 0 stars ) - runabove/queue-examples - OVH Queue - Kafka client examples
( 2017-02-20 / 59 commits / 0 stars ) - saveav/kafka-go-example - Demo for doing event driven in Go using Kafka as the message brocker
( 2017-03-10 / 2 commits / 0 stars ) - sectioneight/kafkabench - Simple tool for benchmarking kafka performance in Go
( 2015-05-15 / 17 commits / 0 stars ) - shopify/sarama - Sarama is a Go library for Apache Kafka 0.8, 0.9, and 0.10.
( 2017-03-12 / 1,511 commits / 340 stars ) - sourcec0de/lmq - An embed queue, like Kafka.
( 2016-10-11 / 223 commits / 0 stars ) - supereagle/kafka-goclient-perf-test - Performance Test for Kafak clents of Go
( 2016-12-09 / 2 commits / 0 stars ) - supershabam/sarama-cg - A pluggable Kafka 0.9+ consumer group coordinator built on https://github.com/Shopify/sarama
( 2016-11-15 / 25 commits / 0 stars ) - thbkrkr/zkafkapi - API to manage Kafka topics and consumers
( 2016-12-09 / 20 commits / 0 stars ) - travisjeffery/jocko - Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install)
( 2017-03-02 / 198 commits / 72 stars ) - travisjeffery/kafka-statsd - Send your Kafka offset lags to StatsD.
( 2016-12-02 / 12 commits / 2 stars ) - truppert/pegasus - Pegasus is a library that allows very simple consuming of a kafka topic
( 2016-09-02 / 2 commits / 0 stars ) - trustedanalytics-ng/gateway - Simple websocket bridge with kafka back-end
( 2017-02-24 / 18 commits / 0 stars ) - trustedanalytics/gateway - Simple bridge from WebSocket to Kafka
( 2016-03-21 / 11 commits / 0 stars ) - tsenart/gofka - Dependency free drop-in replacement for Kafka written in Go.
( 2015-01-15 / 37 commits / 0 stars ) - ubergarm/queuefka - A kafka inspired embedded persistent Apend Only Log message queue.
( 2016-12-29 / 2 commits / 0 stars ) - upsight/franz - Convenience wrappers around Shopify's Sarama
( 2017-02-28 / 11 commits / 0 stars ) - uswitch/loglet - Forward journald log messages to Kafka
( 2017-01-10 / 16 commits / 0 stars ) - vamsi-subhash/kafka-lite - Hackday project for implementing some of the the kafka protocol in go (just for fun)
( 2017-01-22 / 39 commits / 0 stars ) - vrischmann/koff - koff is a small tool to get information about Kafka offsets.
( 2016-08-29 / 34 commits / 0 stars ) - wangdrew/kafka-go - Messing around with sarama, the Kafka golang library
( 2017-02-24 / 5 commits / 0 stars ) - wangshichun/kafka_consumer_monitor_go - monitor the pending message count of consumer of kafka: native or storm consumer
( 2016-08-24 / 5 commits / 0 stars ) - wolfester/easykafkaproducer - ---
( 2016-02-25 / 4 commits / 0 stars ) - wvanbergen/kafka - Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.
( 2016-09-27 / 210 commits / 83 stars ) - wvanbergen/kazoo-go - Go library to access Kafka metadata in Zookeeper
( 2016-09-30 / 49 commits / 31 stars ) - xorlev/gregor - Minimalistic Kafka clone in Go
( 2015-05-19 / 17 commits / 0 stars ) - xstevens/k - A general command line client for Apache Kafka.
( 2016-10-25 / 36 commits / 2 stars ) - xtaci/rewind - Text-Based UI for Kafka
( 2017-02-10 / 29 commits / 2 stars ) - xtaci/sp - Stream Processors on Kafka in Golang
( 2017-02-05 / 92 commits / 0 stars ) - ybrs/d.adams - some kind of simple pub/sub server, inspired by kafka
( 2016-08-31 / 11 commits / 0 stars ) - zorkian/marshal - A Kafka consumer coordination library for Go.
( 2017-01-12 / 208 commits / 13 stars )
- krallistic/kafka-operator: 2017-03-24
[WIP] A Kafka Operator for Kubernetes - marianogappa/bookie: 2017-03-24
Indexing for Kafka queues. - mailgun/kafka-pixy: 2017-03-23
gRPC/REST proxy for Kafka - fgeller/kt: 2017-03-22
Kafka command line tool - msales/kage: 2017-03-22
Kafka metrics agent. - funkygao/dbus: 2017-03-22
yet another databus that transfer/transform pipeline data between plugins - jbanier/passeplat: 2017-03-21
small go thingy that shift data around, from syslog to kafka is the first step. - hieutrtr/imaginary-backup-consumer: 2017-03-21
backup data by consume message from kafka - banno/terraform-provider-mesoskafka: 2017-03-20
Terraform Provider for the Mesos Kafka Scheduler API - financial-times/message-queue-go-producer: 2017-03-20
Kafka Proxy go producer library - responsible for writing messages to kafka, through the kafka proxy. - funkygao/gafka: 2017-03-20
A full ecosystem that is built around kafka powered by golang - ansrivas/fwatcher: 2017-03-19
An application to watch a given directory for new files, read it and publish to Kafka ( using actors ) - rafaeljesus/event-srv: 2017-03-19
An event aggregation service for microservices ⌛ - redborder/dynamic-sensors-watcher: 2017-03-16
Service for allowing new sensors IP by watching a serial number netflow option template - onsdigital/dp-csv-splitter: 2017-03-16
A simple large CSV file splitter that creates Kafka messages from them - movio/kasper: 2017-03-16
Kasper is a Go library for Kafka stream processing - bsm/sarama-cluster: 2017-03-14
--- - shopify/sarama: 2017-03-12
Sarama is a Go library for Apache Kafka 0.8, 0.9, and 0.10. - landoop/kafka-connectors-tests: 2017-03-10
Test suite for Kafka Connect connectors based on Landoop's Coyote and docker. - meteogroup/amqp-to-kafka: 2017-03-10
Fetches messages from AMQP and forwards them to Kafka - saveav/kafka-go-example: 2017-03-10
Demo for doing event driven in Go using Kafka as the message brocker - meteogroup/sqs-to-kafka: 2017-03-09
Fetches messages from SQS and forwards them to Kafka - l0vest0rm/connpool: 2017-03-08
connection pool for go/golang to connect with redis/kafka/hbase/mysql and anything else - myself659/chanbroker: 2017-03-08
ChanBroker, a Broker for goroutine, is simliar to kafka - linkedin/burrow: 2017-03-07
Kafka Consumer Lag Checking - mkocikowski/hbuf: 2017-03-05
User friendly implementation of ideas behind Kafka - confluentinc/confluent-kafka-go: 2017-03-03
Confluent's Apache Kafka Golang client - travisjeffery/jocko: 2017-03-02
Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install) - upsight/franz: 2017-02-28
Convenience wrappers around Shopify's Sarama - foxcomm/metamorphosis: 2017-02-27
The simple Kafka client in GoLang! Read and transform messages with ease. - trustedanalytics-ng/gateway: 2017-02-24
Simple websocket bridge with kafka back-end - wangdrew/kafka-go: 2017-02-24
Messing around with sarama, the Kafka golang library - mediamath/sr: 2017-02-23
Publish schemas to confluent schema-registry - anthonyserious/go-kafka-test: 2017-02-23
Test building mircoservices with go and kafka - roblaszczak/clikafka: 2017-02-23
Simple CLI tool for Kafka written in GO (Golang) - runabove/queue-examples: 2017-02-20
OVH Queue - Kafka client examples - marianogappa/flowbro: 2017-02-19
Real-time flowchart visualisation for Kafka-based distributed systems. - lancewf/sarama: 2017-02-16
Example using the sarama with kafka to add and retrieve messages from the stream - roblaszczak/gotify: 2017-02-16
Notifications framework - ctrlaltdel121/kafkacat-hk: 2017-02-11
Kafkacat wrapper for Heroku Kafka - xtaci/rewind: 2017-02-10
Text-Based UI for Kafka - rafaeljesus/kafka-event-bus: 2017-02-06
A tiny wrapper around https://github.com/Shopify/sarama topic and consumer 🚌 - xtaci/sp: 2017-02-05
Stream Processors on Kafka in Golang - jurriaan/kafkatools: 2017-02-04
CLI tools for monitoring and managing Apache Kafka - philipjkim/kafka-sample-go: 2017-02-02
Kafka pub/sub sample in Go - gleicon/kafka-shell: 2017-02-02
golang shell utilities for kafka - optiopay/kafka: 2017-01-27
Go driver for Kafka - randrr/kafka-example: 2017-01-25
An example on how to use Kafka with Golang. - marekgalovic/kafka-mysql: 2017-01-24
Kafka to mysql importer - pryz/kafka-training: 2017-01-24
Kafka training with Docker - jdamick/kafka: 2017-01-24
Producer and Consumer for Kafka in Go - vamsi-subhash/kafka-lite: 2017-01-22
Hackday project for implementing some of the the kafka protocol in go (just for fun) - matthias-margush/cdrt-kafka-go: 2017-01-22
CDRTs in Go, over Kafka - financial-times/coco-kafka-bridge: 2017-01-19
Kafka consumer forwarding messages to an HTTP endpoint. - meitu/go-consumergroup: 2017-01-19
golang kafka consumer group - datamountaineer/schema-registry: 2017-01-15
A CLI and Go client for Confluent's Kafka Schema Registry - philipjkim/kafka-brokers-go: 2017-01-13
Go library to access Kafka broker list in Zookeeper - zorkian/marshal: 2017-01-12
A Kafka consumer coordination library for Go. - moul/kafka-gateway: 2017-01-11
🌊 Kafka Gateway (gRPC/protobuf + http/json) - uswitch/loglet: 2017-01-10
Forward journald log messages to Kafka - majidgolshadi/kafka-consumer: 2017-01-07
Self balancing kafka consumer - jeffail/benthos: 2017-01-03
A persistent stream buffer - hellofresh/kandalf: 2017-01-02
RabbitMQ to Kafka bridge - ombits/kafkaproducer: 2016-12-30
--- - ubergarm/queuefka: 2016-12-29
A kafka inspired embedded persistent Apend Only Log message queue. - go-wave/ykafka: 2016-12-29
ykafka is kafka repro for use low api read kafka and save offset - jamiealquiza/sangrenel: 2016-12-15
Apache Kafka load testing: "...basically a cloth bag filled with small jagged pieces of scrap iron" - mhausenblas/dnpipes: 2016-12-14
Distributed Named Pipes - jianchen2580/log-stream: 2016-12-14
streaming kafka logs - supereagle/kafka-goclient-perf-test: 2016-12-09
Performance Test for Kafak clents of Go - thbkrkr/zkafkapi: 2016-12-09
API to manage Kafka topics and consumers - mudit2108/docker-kafka: 2016-12-07
Apache Kafka cluster implemented with Docker - garo/logs2kafka: 2016-12-05
Simple tool to listen incoming json based log events on TCP socket and forward them to Kafka - brxie/kafka-gtk: 2016-12-02
GUI application for exchanging messages from Apache Kafka clusters - travisjeffery/kafka-statsd: 2016-12-02
Send your Kafka offset lags to StatsD. - germanramos/kafka-console-producer: 2016-11-30
--- - kochava/firehose: 2016-11-22
A Kafka topic transfer agent - supershabam/sarama-cg: 2016-11-15
A pluggable Kafka 0.9+ consumer group coordinator built on https://github.com/Shopify/sarama - movio/go-kafka: 2016-10-31
Assorted Golang Kafka utils - financial-times/kafka-lagcheck: 2016-10-27
Kafka Consumer Lag Checking - andreas-schroeder/kafka-health-check: 2016-10-26
Health Check for Kafka Brokers. - xstevens/k: 2016-10-25
A general command line client for Apache Kafka. - dnance/lab-reservation: 2016-10-20
sample kafka consumers and producers - financial-times/kmt-kafka-sync: 2016-10-20
A µService to listen for whitelisted events on Kafka and post them to Kinesis for processing via Lambda - jhaynie/github-webhook-kafka: 2016-10-17
Github Webhook -> Kafka server - jaehue/anyq: 2016-10-16
Queue library wrapper for widely popular queues - RabitMQ, Kafka, NSQ, NATS - sourcec0de/lmq: 2016-10-11
An embed queue, like Kafka. - redborder/k2http: 2016-10-10
Forwards messages from kafka to an HTTP endpoint. - kchristidis/kafka-orderer: 2016-10-09
The prototype of what later became the Kafka-based ordering service for Hyperledger Fabric. (This repo is no longer maintained; kept for historical reasons.) Please see: https://github.com/hyperledger/fabric/tree/master/orderer - cafxx/kafkabalancer: 2016-10-06
Automatically rebalance your kafka topics, partitions, replicas across your cluster - wvanbergen/kazoo-go: 2016-09-30
Go library to access Kafka metadata in Zookeeper - moemoe89/simple-avro-kafka-golang: 2016-09-28
Simple Avro Kafka using Golang for Producer and Consumer - moemoe89/simple-kafka-golang: 2016-09-28
Simple Kafka using Golang for Producer and Consumer - wvanbergen/kafka: 2016-09-27
Load-balancing, resuming Kafka consumer for go, backed by Zookeeper. - ninibe/netlog: 2016-09-22
A lightweight, HTTP-centric, log-based (Kafka-style) message queue. [WIP] - mediamath/kafka-proxy: 2016-09-13
A golang library for working with the Confluent Kafka Restful proxy - corybuecker/kafka-testing: 2016-09-10
A Docker-based set of programs to send and receive messages through a Kafka cluster. - h12w/kpax: 2016-09-06
A modular & idiomatic Kafka client in Go - germanramos/kafka-console-consumer: 2016-09-05
--- - truppert/pegasus: 2016-09-02
Pegasus is a library that allows very simple consuming of a kafka topic - ybrs/d.adams: 2016-08-31
some kind of simple pub/sub server, inspired by kafka - vrischmann/koff: 2016-08-29
koff is a small tool to get information about Kafka offsets. - wangshichun/kafka_consumer_monitor_go: 2016-08-24
monitor the pending message count of consumer of kafka: native or storm consumer - go-kafka/connect: 2016-08-11
CLI tool and Go client library for the Kafka Connect REST API - rollulus/kafcat: 2016-07-26
Tool for Kafka - financial-times/kafkaduct: 2016-07-12
Kafka HTTP to local kafka - allmad/madq: 2016-07-11
[WIP] A high performance message queue, inspired by kafka - jeffallen/kboing: 2016-06-14
A load generator for Kafka - elodina/go_kafka_client: 2016-05-13
Apache Kafka Client Library for Go - elodina/siesta: 2016-04-25
Making support for Apache Kafka in Go better - elodina/go-kafka-avro: 2016-04-22
go-kafka-avro implements Avro encoding and decoding compatible with Confluent Schema Registry. - gfremex/logrus-kafka-hook: 2016-03-29
A logrus.Hook which sends a single log entry to multiple kafka topics simultaneously. - trustedanalytics/gateway: 2016-03-21
Simple bridge from WebSocket to Kafka - esdb/kafka-agent: 2016-03-10
Persist to local durable storage before sending to kafka, solve the logging problem once for all - orbat/krater: 2016-03-01
An io.Writer / io.ReaderFrom that produces to Kafka - wolfester/easykafkaproducer: 2016-02-25
--- - pmdcosta/apache-kafka: 2016-02-19
Docker containers for an Apache Kafka cluster - nickbruun/gokafkagroupconsumer: 2016-01-26
Kafka 0.9+ group consumer for Go based on Shopify's sarama library - legionus/kafka-replicator: 2015-11-19
Kafka messages replicator - adxhyt/kafka-zookeeper-monitor: 2015-11-12
yet another kafka monitor by zookeeper - ian-kent/ktail: 2015-10-23
Tail a Kafka topic (see https://github.com/ian-kent/ktee) - kasey/camus: 2015-10-08
what comes after kafka? - ian-kent/ktee: 2015-09-25
Tee to a Kafka topic (see https://github.com/ian-kent/ktail) - h12w/kafkaq: 2015-08-07
A Simple Message & Job Queue Based on Kafka - nesze/kafka-bridge: 2015-06-18
Kafka consumer publishing the messages to an HTTP endpoint. - xorlev/gregor: 2015-05-19
Minimalistic Kafka clone in Go - sectioneight/kafkabench: 2015-05-15
Simple tool for benchmarking kafka performance in Go - chenziliang/descartes.legacy: 2015-05-13
Data collecting infrastructure based on Kafka and Splunk - elodina/go-kafka: 2015-04-21
Quick up and running using Go for Apache Kafka - tsenart/gofka: 2015-01-15
Dependency free drop-in replacement for Kafka written in Go.
- funkygao/gafka: 151.10 MB
(81.72 MB git / 69.38 MB code) - ansrivas/fwatcher: 91.68 MB
(17.33 MB git / 74.35 MB code) - krallistic/kafka-operator: 84.84 MB
(13.99 MB git / 70.85 MB code) - moul/kafka-gateway: 40.51 MB
(7.13 MB git / 33.38 MB code) - marianogappa/flowbro: 30.56 MB
(25.27 MB git / 5.30 MB code) - moemoe89/simple-avro-kafka-golang: 18.42 MB
(7.37 MB git / 11.05 MB code) - xtaci/sp: 15.41 MB
(1.41 MB git / 13.99 MB code) - financial-times/kmt-kafka-sync: 14.64 MB
(3.52 MB git / 11.13 MB code) - dnance/lab-reservation: 12.89 MB
(5.20 MB git / 7.69 MB code) - wangshichun/kafka_consumer_monitor_go: 9.47 MB
(2.35 MB git / 7.12 MB code) - vamsi-subhash/kafka-lite: 9.17 MB
(9.14 MB git / 0.03 MB code) - elodina/go_kafka_client: 8.24 MB
(6.12 MB git / 2.12 MB code) - supereagle/kafka-goclient-perf-test: 7.03 MB
(3.07 MB git / 3.96 MB code) - moemoe89/simple-kafka-golang: 6.85 MB
(1.67 MB git / 5.18 MB code) - banno/terraform-provider-mesoskafka: 6.81 MB
(3.95 MB git / 2.86 MB code) - onsdigital/dp-csv-splitter: 6.45 MB
(4.32 MB git / 2.13 MB code) - thbkrkr/zkafkapi: 6.16 MB
(1.17 MB git / 4.99 MB code) - runabove/queue-examples: 6.02 MB
(4.88 MB git / 1.14 MB code) - xtaci/rewind: 5.94 MB
(1.10 MB git / 4.84 MB code) - marianogappa/bookie: 5.36 MB
(0.95 MB git / 4.41 MB code) - sourcec0de/lmq: 5.11 MB
(0.92 MB git / 4.18 MB code) - brxie/kafka-gtk: 4.80 MB
(4.41 MB git / 0.39 MB code) - travisjeffery/jocko: 4.57 MB
(4.42 MB git / 0.15 MB code) - uswitch/loglet: 4.43 MB
(0.77 MB git / 3.66 MB code) - mailgun/kafka-pixy: 4.35 MB
(2.01 MB git / 2.35 MB code) - jaehue/anyq: 4.04 MB
(3.99 MB git / 0.05 MB code) - majidgolshadi/kafka-consumer: 3.65 MB
(3.64 MB git / 0.01 MB code) - financial-times/kafkaduct: 3.43 MB
(2.91 MB git / 0.52 MB code) - cafxx/kafkabalancer: 3.35 MB
(3.31 MB git / 0.04 MB code) - jhaynie/github-webhook-kafka: 3.17 MB
(0.90 MB git / 2.27 MB code) - go-kafka/connect: 3.03 MB
(0.77 MB git / 2.27 MB code) - jeffail/benthos: 2.75 MB
(2.31 MB git / 0.44 MB code) - meitu/go-consumergroup: 2.56 MB
(2.52 MB git / 0.04 MB code) - elodina/go-kafka: 2.50 MB
(1.03 MB git / 1.47 MB code) - jamiealquiza/sangrenel: 2.50 MB
(1.93 MB git / 0.57 MB code) - shopify/sarama: 2.49 MB
(1.97 MB git / 0.53 MB code) - redborder/dynamic-sensors-watcher: 2.46 MB
(2.38 MB git / 0.09 MB code) - mhausenblas/dnpipes: 2.39 MB
(1.50 MB git / 0.89 MB code) - jurriaan/kafkatools: 2.21 MB
(2.16 MB git / 0.05 MB code) - zorkian/marshal: 2.19 MB
(1.97 MB git / 0.21 MB code) - germanramos/kafka-console-consumer: 1.64 MB
(0.49 MB git / 1.14 MB code) - corybuecker/kafka-testing: 1.59 MB
(0.42 MB git / 1.18 MB code) - fgeller/kt: 1.45 MB
(0.68 MB git / 0.77 MB code) - trustedanalytics/gateway: 1.42 MB
(0.41 MB git / 1.01 MB code) - trustedanalytics-ng/gateway: 1.41 MB
(0.55 MB git / 0.86 MB code) - ninibe/netlog: 1.23 MB
(0.40 MB git / 0.83 MB code) - allmad/madq: 1.09 MB
(0.97 MB git / 0.12 MB code) - funkygao/dbus: 0.97 MB
(0.80 MB git / 0.17 MB code) - chenziliang/descartes.legacy: 0.90 MB
(0.74 MB git / 0.16 MB code) - germanramos/kafka-console-producer: 0.85 MB
(0.25 MB git / 0.60 MB code) - movio/go-kafka: 0.82 MB
(0.23 MB git / 0.59 MB code) - anthonyserious/go-kafka-test: 0.79 MB
(0.78 MB git / 0.01 MB code) - h12w/kpax: 0.74 MB
(0.44 MB git / 0.30 MB code) - optiopay/kafka: 0.73 MB
(0.46 MB git / 0.27 MB code) - confluentinc/confluent-kafka-go: 0.48 MB
(0.22 MB git / 0.27 MB code) - upsight/franz: 0.45 MB
(0.44 MB git / 0.01 MB code) - kasey/camus: 0.43 MB
(0.14 MB git / 0.30 MB code) - elodina/siesta: 0.43 MB
(0.23 MB git / 0.20 MB code) - movio/kasper: 0.42 MB
(0.30 MB git / 0.12 MB code) - linkedin/burrow: 0.37 MB
(0.24 MB git / 0.14 MB code) - landoop/kafka-connectors-tests: 0.35 MB
(0.22 MB git / 0.13 MB code) - wvanbergen/kafka: 0.33 MB
(0.27 MB git / 0.06 MB code) - bsm/sarama-cluster: 0.30 MB
(0.24 MB git / 0.06 MB code) - kchristidis/kafka-orderer: 0.27 MB
(0.15 MB git / 0.12 MB code) - financial-times/coco-kafka-bridge: 0.26 MB
(0.21 MB git / 0.05 MB code) - mudit2108/docker-kafka: 0.23 MB
(0.08 MB git / 0.15 MB code) - roblaszczak/gotify: 0.22 MB
(0.11 MB git / 0.11 MB code) - andreas-schroeder/kafka-health-check: 0.21 MB
(0.12 MB git / 0.09 MB code) - jdamick/kafka: 0.20 MB
(0.14 MB git / 0.07 MB code) - mkocikowski/hbuf: 0.18 MB
(0.09 MB git / 0.09 MB code) - vrischmann/koff: 0.18 MB
(0.16 MB git / 0.02 MB code) - travisjeffery/kafka-statsd: 0.17 MB
(0.09 MB git / 0.08 MB code) - hellofresh/kandalf: 0.17 MB
(0.12 MB git / 0.05 MB code) - msales/kage: 0.16 MB
(0.10 MB git / 0.05 MB code) - orbat/krater: 0.14 MB
(0.06 MB git / 0.08 MB code) - redborder/k2http: 0.13 MB
(0.08 MB git / 0.05 MB code) - wvanbergen/kazoo-go: 0.12 MB
(0.07 MB git / 0.05 MB code) - pmdcosta/apache-kafka: 0.12 MB
(0.07 MB git / 0.05 MB code) - garo/logs2kafka: 0.11 MB
(0.07 MB git / 0.05 MB code) - supershabam/sarama-cg: 0.10 MB
(0.06 MB git / 0.04 MB code) - legionus/kafka-replicator: 0.10 MB
(0.06 MB git / 0.04 MB code) - mediamath/sr: 0.09 MB
(0.06 MB git / 0.03 MB code) - kochava/firehose: 0.09 MB
(0.06 MB git / 0.03 MB code) - elodina/go-kafka-avro: 0.09 MB
(0.06 MB git / 0.03 MB code) - meteogroup/amqp-to-kafka: 0.09 MB
(0.06 MB git / 0.03 MB code) - meteogroup/sqs-to-kafka: 0.08 MB
(0.05 MB git / 0.03 MB code) - pryz/kafka-training: 0.08 MB
(0.07 MB git / 0.02 MB code) - financial-times/kafka-lagcheck: 0.08 MB
(0.06 MB git / 0.02 MB code) - ybrs/d.adams: 0.08 MB
(0.06 MB git / 0.03 MB code) - tsenart/gofka: 0.08 MB
(0.06 MB git / 0.02 MB code) - xstevens/k: 0.07 MB
(0.05 MB git / 0.02 MB code) - xorlev/gregor: 0.07 MB
(0.05 MB git / 0.01 MB code) - hieutrtr/imaginary-backup-consumer: 0.06 MB
(0.06 MB git / 0.01 MB code) - datamountaineer/schema-registry: 0.06 MB
(0.05 MB git / 0.02 MB code) - esdb/kafka-agent: 0.06 MB
(0.04 MB git / 0.02 MB code) - rafaeljesus/event-srv: 0.06 MB
(0.04 MB git / 0.02 MB code) - marekgalovic/kafka-mysql: 0.06 MB
(0.04 MB git / 0.02 MB code) - financial-times/message-queue-go-producer: 0.06 MB
(0.04 MB git / 0.02 MB code) - mediamath/kafka-proxy: 0.05 MB
(0.03 MB git / 0.02 MB code) - nesze/kafka-bridge: 0.05 MB
(0.04 MB git / 0.01 MB code) - myself659/chanbroker: 0.05 MB
(0.04 MB git / 0.01 MB code) - foxcomm/metamorphosis: 0.05 MB
(0.04 MB git / 0.01 MB code) - adxhyt/kafka-zookeeper-monitor: 0.04 MB
(0.03 MB git / 0.01 MB code) - sectioneight/kafkabench: 0.04 MB
(0.04 MB git / 0.00 MB code) - ubergarm/queuefka: 0.04 MB
(0.03 MB git / 0.02 MB code) - h12w/kafkaq: 0.04 MB
(0.03 MB git / 0.01 MB code) - randrr/kafka-example: 0.04 MB
(0.03 MB git / 0.01 MB code) - wolfester/easykafkaproducer: 0.04 MB
(0.02 MB git / 0.02 MB code) - rollulus/kafcat: 0.04 MB
(0.03 MB git / 0.01 MB code) - go-wave/ykafka: 0.04 MB
(0.03 MB git / 0.01 MB code) - jbanier/passeplat: 0.03 MB
(0.03 MB git / 0.00 MB code) - rafaeljesus/kafka-event-bus: 0.03 MB
(0.03 MB git / 0.01 MB code) - l0vest0rm/connpool: 0.03 MB
(0.03 MB git / 0.01 MB code) - jianchen2580/log-stream: 0.03 MB
(0.02 MB git / 0.01 MB code) - philipjkim/kafka-sample-go: 0.03 MB
(0.02 MB git / 0.01 MB code) - ian-kent/ktee: 0.03 MB
(0.02 MB git / 0.01 MB code) - ctrlaltdel121/kafkacat-hk: 0.03 MB
(0.02 MB git / 0.01 MB code) - gleicon/kafka-shell: 0.03 MB
(0.02 MB git / 0.01 MB code) - lancewf/sarama: 0.03 MB
(0.02 MB git / 0.01 MB code) - roblaszczak/clikafka: 0.03 MB
(0.02 MB git / 0.01 MB code) - wangdrew/kafka-go: 0.03 MB
(0.02 MB git / 0.00 MB code) - truppert/pegasus: 0.03 MB
(0.02 MB git / 0.01 MB code) - nickbruun/gokafkagroupconsumer: 0.03 MB
(0.02 MB git / 0.01 MB code) - jeffallen/kboing: 0.03 MB
(0.02 MB git / 0.01 MB code) - philipjkim/kafka-brokers-go: 0.02 MB
(0.02 MB git / 0.00 MB code) - matthias-margush/cdrt-kafka-go: 0.02 MB
(0.02 MB git / 0.01 MB code) - gfremex/logrus-kafka-hook: 0.02 MB
(0.02 MB git / 0.01 MB code) - saveav/kafka-go-example: 0.02 MB
(0.02 MB git / 0.00 MB code) - ian-kent/ktail: 0.02 MB
(0.02 MB git / 0.00 MB code) - ombits/kafkaproducer: 0.02 MB
(0.02 MB git / 0.00 MB code)