Open-Awesome
CategoriesAlternativesStacksSelf-HostedExplore
Open-Awesome

© 2026 Open-Awesome. Curated for the developer elite.

TermsPrivacyAboutGitHubRSS
  1. Home
  2. Tags
  3. Kafka

Kafka

109 projects

Showing 36 of 109 projects

trubka
trubkaGo

A CLI tool for managing, consuming, and publishing messages to Kafka clusters with protocol buffer support.

#devops#protobuf-parser#message-queue
Stars337
Forks20
Last commit1 year ago
AMQP 1.0 - Kafka bridge
AMQP 1.0 - Kafka bridgeJava

An HTTP bridge enabling HTTP 1.1 clients to send and receive messages to/from Apache Kafka clusters.

#hacktoberfest#strimzi#message-queue
Stars335
Forks136
Last commit6 days ago
ksqlDB
ksqlDBJava

A distributed, scalable database built for stream processing applications on Apache Kafka using SQL syntax.

#stream-processing#ksqldb#materialized-views
Stars311
Forks1.0k
Last commit21 hours ago
Kroxylicious
KroxyliciousJava

A snappy open-source proxy for Apache Kafka that enables encryption, multi-tenancy, and schema validation.

#custom-filters#kafka-proxy#proxy
Stars296
Forks121
Last commit22 hours ago
Silverback
SilverbackC#

A .NET message bus and broker integration library for building event-driven architectures with first-class Apache Kafka and MQTT support.

#silverback#service-bus#event-driven-architecture
Stars284
Forks43
Last commit1 day ago
Confluent's .NET Client
Confluent's .NET ClientC#

Confluent's official .NET client for Apache Kafka, built on librdkafka for high performance and reliability.

#stream-processing#event-driven#nuget
Stars268
Forks896
Last commit1 day ago
tcpdog
tcpdogGo

eBPF-based tool for efficient TCP observability, exporting kernel-level socket statistics to Elasticsearch, ClickHouse, or InfluxDB.

#bpf#tcp#observability
Stars261
Forks22
Last commit5 years ago
workflow
workflowGo

A type-safe, event-driven workflow orchestration library for building robust, distributed workflows in Go with compile-time safety and horizontal scaling.

#event-driven#statemachine#workflow
Stars250
Forks22
Last commit4 days ago
kcli
kcliGo

A read-only command-line browser for exploring Kafka topics, partitions, and messages with search and custom decoding.

#devops#streaming-data#command-line-tool
Stars224
Forks17
Last commit6 years ago
phobos
phobosRuby

A micro framework and library for Ruby applications to simplify consuming and producing messages with Apache Kafka.

#event-driven#message-queue#ruby-kafka
Stars218
Forks37
Last commit1 year ago
xk6-kafka
xk6-kafkaGo

A k6 extension for load testing Apache Kafka with support for multiple serialization formats, authentication, compression, and Schema Registry.

#load-testing#performance-testing#message-queue
Stars215
Forks98
Last commit6 days ago
Scheduler
SchedulerScala

A fault-tolerant Scala library for scheduling arbitrary code to run at arbitrary times across distributed systems.

#job-scheduler#scala-library#distributed-systems
Stars213
Forks37
Last commit4 years ago
Streamline
StreamlineJava

A visual development platform for building, deploying, and managing streaming analytics applications with multiple engine bindings.

#stream-processing#flink#storm
Stars167
Forks95
Last commit2 years ago
kaffe
kaffeElixir

An opinionated Elixir wrapper around the Brod Kafka client with built-in support for Heroku Kafka and encrypted connections.

#elixir#batch-processing#message-queue
Stars164
Forks62
Last commit2 days ago
schema_registry_converter
schema_registry_converterRust

A Rust crate for encoding and decoding data compatible with the Confluent Schema Registry, supporting Avro, Protobuf, and JSON Schema.

#confluent-compatible#async-rust#kafka
Stars118
Forks51
Last commit
samza-luwak
samza-luwakJava

An experimental integration of Apache Samza and Luwak for scalable real-time document matching against large query sets.

#stream-processing#media-monitoring#luwak
Stars100
Forks15
Last commit11 years ago
Kafka
KafkaOCaml

OCaml bindings for Apache Kafka, enabling Kafka client functionality in OCaml applications.

#stream-processing#functional-programming#message-queue
Stars72
Forks12
Last commit2 years ago
gatling-kafka
gatling-kafkaScala

An unofficial Gatling plugin for stress testing Apache Kafka producer API.

#load-testing#stress-testing#performance-testing
Stars67
Forks71
Last commit5 years ago
terraform-aws-msk-kafka-cluster
terraform-aws-msk-kafka-clusterHCL

A Terraform module for provisioning and managing AWS Managed Streaming for Apache Kafka (MSK) clusters.

#cloud-infrastructure#devops#streaming-data
Stars61
Forks76
Last commit
psql-streamer
psql-streamerGo

Streams PostgreSQL database events to Kafka using logical replication and can also consume events from Kafka.

#logical-replication#event-driven#replication
Stars61
Forks13
Last commit6 years ago
python-cqrs
python-cqrsPython

A Python framework for building event-driven distributed systems using CQRS, sagas, and transactional outbox patterns.

#fastapi#event-driven#event-driven-architecture
Stars61
Forks8
Last commit1 day ago
go-graphql-subscription-example
go-graphql-subscription-exampleGo

A Go-based GraphQL subscription server example that consumes messages from Kafka, Redis, and NSQ streams.

#redis#graphql#redis-streams
Stars47
Forks5
Last commit15 days ago
Influx-Capacitor
Influx-CapacitorC#

Collects Windows Performance Counter metrics and sends them to InfluxDB for visualization in Grafana.

#windows-service#metrics-collection#performance-counters
Stars45
Forks13
Last commit9 years ago
Maki Nage
Maki NagePython

Stream Processing Made Easy

#stream-processing#reactive-systems#distributed-systems
Stars42
Forks1
Last commit4 years ago
Swifka
SwifkaSwift

A native macOS Kafka monitoring client designed to be lightweight, safe, and read-only for production environments.

#observability#message-decoding#read-only
Stars36
Forks3
Last commit5 days ago
xk6-opentelemetry
xk6-opentelemetryGo

A k6 extension for generating random OpenTelemetry signals (metrics, logs, traces) to test observability pipelines.

#load-testing#integration-testing#observability
Stars34
Forks1
Last commit2 years ago
jmeter-backend-listener-kafka
jmeter-backend-listener-kafkaJava

A JMeter plugin that sends performance test results to a Kafka server for real-time analysis.

#load-testing#performance-testing#jmeter
Stars33
Forks18
Last commit4 years ago
xk6-output-kafka
xk6-output-kafkaGo

A k6 extension that streams real-time load test metrics to Apache Kafka topics for real-time monitoring and analysis.

#load-testing#k6#k6-extension
Stars26
Forks8
Last commit3 months ago
ApplicantAtlas
ApplicantAtlasTypeScript

An open-source platform for managing hackathon applicants, RSVPs, and communications.

#hackathon#open-source#hackathons
Stars24
Forks5
Last commit1 year ago
gatling-kafka-plugin
gatling-kafka-pluginScala

A Gatling protocol plugin for load testing Apache Kafka with support for Avro schemas and request-reply patterns.

#load-testing#performance-testing#message-queue
Stars22
Forks5
Last commit1 month ago
pletter
pletterGo

A Go library for standardizing the wrapping of protocol buffer messages in event-driven architectures.

#stream-processing#message-enveloping#event-driven-architecture
Stars20
Forks3
Last commit7 months ago
crafka
crafkaCrystal

A Kafka client library for Crystal built on librdkafka, supporting both producing and consuming messages.

#message-queue#librdkafka#distributed-systems
Stars20
Forks5
Last commit1 year ago
Hortonworks Schema Registry
Hortonworks Schema RegistryJava

A framework for building metadata repositories, currently featuring a SchemaRegistry implementation.

#kinesis#schemas#flink
Stars18
Forks10
Last commit2 years ago
javactrl-kafka
javactrl-kafkaJava

A minimalistic workflow engine for JVM that defines workflows as Java functions and runs them as Apache Kafka Streams processors.

#workflow-management#workflow#workflow-engine
Stars18
Forks5
Last commit1 year ago
broker
brokerGo

A production-grade messaging abstraction layer for Go that unifies APIs across Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS.

#event-driven#redis#distributed-systems
Stars11
Forks1
Last commit6 months ago
Cassandra.Lunch
Cassandra.Lunch

A weekly online meetup and resource hub for Apache Cassandra topics, featuring talks, tutorials, and community discussions.

#airflow#devops#akka
Stars10
Forks9
Last commit2 years ago
PreviousPage 3 of 4Next

Related Tags

Community-curated · Updated weekly · 100% open source

Found a gem we're missing?

Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.

Submit a projectStar on GitHub
11 days ago
3 months ago
#Apache Kafka37
#Stream Processing33
#Distributed Systems30
#Message Queue28
#Microservices25
#Event Driven18
#Data Pipeline18
#Go17
#Rust15
#Java14
#Event Streaming13
#Data Streaming12