A simple CLI utility for monitoring protobuf-encoded messages in Kafka topics
A simple CLI utility for monitoring protobuf-encoded messages in Kafka topics
Stream Maxscale CDC events to Kafka
Stream Maxscale CDC events to Kafka
Kafka Consumer Lag Checking
Kafka Consumer Lag Checking
Observe a PostgreSQL database changes using Debezium and Apache Kafka
Observe a PostgreSQL database changes using Debezium and Apache Kafka.
Mock Kafka Server, useful for testing and experimenting with Kafka
Mock Kafka Server, useful for testing and experimenting with Kafka
Blueprint ROA Golang gRPC Gateway With Emitter Kafka Streams
Blueprint ROA Golang gRPC Gateway With Emitter Kafka Streams
Delay queues that depend on Kafka
Delay queues that depend on Kafka
Benchmark of Kafka libraries for Go
Benchmark of Kafka libraries for Go
Kafka swiss army knife
Kafka swiss army knife
RabbitMQ and Kafka use sample
RabbitMQ and Kafka use sample
CLI to read file by line and send this line to Kafka topic
CLI to read file by line and send this line to Kafka topic
Some convenient functions used to get some info from a kafka cluster
Some convenient functions used to get some info from a kafka cluster
The Kafka events sent by the Vehicle Tracking application and offers the posibility to access them via an http API
The Kafka events sent by the Vehicle Tracking application and offers the posibility to access them via an http API
Stream Kafka messages as Server Sent Events to SSE clients
Stream Kafka messages as Server Sent Events to SSE clients
Benchmarking kraft or Kafka Raft
Benchmarking kraft or Kafka Raft
A minimalistic Kafka go consumer for local and cloud hosted kafka servers
A minimalistic Kafka go consumer for local and cloud hosted kafka servers
User creation with Kafka producer
User creation with Kafka producer
Email service using Kafka consumer
Email service using Kafka consumer
Protoc plugin generate kafka handler
Protoc plugin generate kafka handler
A basic CLI tool to manage kafka clusters
A basic CLI tool to manage kafka clusters
Communication infrastructure PoC using RabbitMQ and Kafka
Communication infrastructure PoC using RabbitMQ and Kafka
Kafka-Pixy: a dual API (gRPC and REST) proxy for Kafka with automatic consumer group control
Kafka-Pixy: a dual API (gRPC and REST) proxy for Kafka with automatic consumer group control
A Kafka log structure inspired in-memory and append-only data structure
A Kafka log structure inspired in-memory and append-only data structure
Kcli: a kafka read only command line browser
Kcli: a kafka read only command line browser
Kafka Connect (connectors / tasks) HealthCheck For AWS ALB and more
Kafka Connect (connectors / tasks) HealthCheck For AWS ALB and more
Stream database events from PostgreSQL to Kafka
Stream database events from PostgreSQL to Kafka
Confluent's Apache Kafka Golang client
Confluent's Apache Kafka Golang client
Franz-go contains a high performance, pure Go library for interacting with Kafka from 0.8.0 through 2.7.0+
Franz-go contains a high performance, pure Go library for interacting with Kafka from 0.8.0 through 2.7.0+
Trubka: a Kafka CLI tool built in Go which gives you everything you need to
Trubka: a Kafka CLI tool built in Go which gives you everything you need to
Message relay written in golang for PostgreSQL and Apache Kafka
Message relay written in golang for PostgreSQL and Apache Kafka
Sarama: a Go library for Apache Kafka 0.8, and up
Sarama: a Go library for Apache Kafka 0.8, and up
Golang Kafka gRPC MongoDB microservice example
Golang Kafka gRPC MongoDB microservice example
Use Consul to do service discovery, use gRPC +kafka to do message produce and consume
Use Consul to do service discovery, use gRPC +kafka to do message produce and consume
Distributed commit log service in Go that is wire compatible with Kafka
Distributed commit log service in Go that is wire compatible with Kafka
SigNoz: Open source Observability Platform
SigNoz: Open source Observability Platform
Build systems with Go examples For Golang
Build systems with Go examples For Golang
kafka watcher for casbin library
kafka watcher for casbin library
Easy to use distributed event bus similar to Kafka
Easy to use distributed event bus similar to Kafka
Implementation of the NELI leader election protocol for Go and Kafka
Implementation of the NELI leader election protocol for Go and Kafka
Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX
Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX
Reference Architecture using SingleStore and Redpanda for global logistics
Reference Architecture using SingleStore and Redpanda for global logistics
A NetFlow/IPFIX/sFlow collector in Go
A NetFlow/IPFIX/sFlow collector in Go
A POC for implementing the Kafka as a message queue along with Golang
A POC for implementing the Kafka as a message queue along with Golang
Kafka Stress : Stress Test Tool for Kafka Clusters, Producers and Consumers Tunning
Kafka Stress : Stress Test Tool for Kafka Clusters, Producers and Consumers Tunning
Kafka/distributed commit log service in Go
Kafka/distributed commit log service in Go
A Broker for goroutine, is simliar to kafka
A Broker for goroutine, is simliar to kafka
Distributed Named Pipes: a distributed version of Unix named pipes
Distributed Named Pipes: a distributed version of Unix named pipes
Gosiris: An actor framework for Go
Gosiris: An actor framework for Go
Crossplane provider for Kafka
Crossplane provider for Kafka
A unconnected fork from Robin Moffatt and will be developed on its own
A unconnected fork from Robin Moffatt and will be developed on its own