* [sarama v1.50.0](https://github.com/IBM/sarama) – Go client library for Apache Kafka. * [kafka cookbook v4.0.0](https://github.com/sous-chefs/kafka) – Installs and configures Kafka version 0.8.1 or higher without managing ZooKeeper. * [kafkactl v5.19.0](https://github.com/deviceinsight/kafkactl) – Command-line interface for interacting with Apache Kafka supporting multiple features like auto-completion and protobuf messages. * [Flexprice 2.1.12](https://github.com/flexprice/flexprice) – Usage metering and billing infrastructure designed for AI companies to streamline pricing models and track usage. * [confluent-schema-registry v4.1.0](https://github.com/kafkajs/confluent-schema-registry) – Library for interacting with Confluent Schema Registry, offering Avro-based encode/decode and schema registration using Confluent wire format. * [GlassFlow v3.2.0](https://github.com/glassflow/clickhouse-etl) – Real-time Kafka-to-ClickHouse ETL with deduplication, temporal joins, and optional direct ingestion. * [RisingWave v2.8.4](https://github.com/risingwavelabs/risingwave) – World's most advanced event stream processing platform for real-time data management and analysis. * [zkafka v2.3.0](https://github.com/zillow/zkafka) – Efficient, Go-based library for stateless Kafka message processing with offset management, virtual partitioning, and dead-letter support. * [TBMQ v2.3.0](https://github.com/thingsboard/tbmq) – Scalable and fault-tolerant MQTT broker capable of handling millions of concurrent connections and messages. * [Rdkafka v0.27.0](https://github.com/karafka/rdkafka-ruby) – Modern Kafka client library for Ruby based on librdkafka. * [KafScale v1.6.0](https://github.com/KafScale/platform) – Kafka-protocol-compatible streaming platform storing durable logs in object storage with stateless ephemeral brokers. * [hmq v1.5.8](https://github.com/fhmq/hmq) – High-performance MQTT broker written in Go with clustering, WebSocket and TLS support. * [Mokapi v0.43.0](https://github.com/marle3003/mokapi) – API mocking tool using OpenAPI and AsyncAPI to simulate HTTP, Kafka, LDAP, and SMTP with JavaScript-driven behaviors. * [Components Contrib v1.17.6](https://github.com/dapr/components-contrib) – Reusable components for interacting with bindings, state stores, messaging, and more in distributed applications. * [fluent-plugin-kafka v0.19.7](https://github.com/fluent/fluent-plugin-kafka) – Plugin for consuming and producing data with Apache Kafka in Fluentd. * [Tools for Apache Kafka v0.30.3](https://github.com/jlandersen/vscode-kafka) – Visual Studio Code extension for interacting with Kafka clusters, browsing topics/brokers/configs, and producing/consuming messages. * [OpenMeter v1.0.0-beta.228](https://github.com/openmeterio/openmeter) – Billing and metering platform for AI, API, and DevOps that aggregates real-time usage events and enforces usage-based limits.