{"repo":"kafkaex/kafka_ex","free":true,"listed":false,"github":"https://github.com/kafkaex/kafka_ex","clone":"git clone https://github.com/kafkaex/kafka_ex.git","description":"Kafka client library for Elixir","language":"Elixir","stars":610,"topics":["kafka","elixir","erlang"],"license":"MIT","category":"data-pipelines","readme_excerpt":"KafkaEx ======== KafkaEx is an Elixir client for Apache Kafka. KafkaEx requires Elixir 1.14+ and Erlang OTP 24+. Supported Kafka versions: 0.11.0 and newer (see Supported Kafka Versions). Project Status KafkaEx v1.0 is the Kayrock-based release. Scope: - ✅ Producer, consumer groups, admin APIs - ✅ SASL (PLAIN, SCRAM-256/512, OAUTHBEARER, AWS MSK IAM) - ✅ Compression (gzip, snappy, lz4, zstd) - ✅ Automatic API version negotiation with per-request / per-app overrides - ✅ First-class telemetry (27+ events) - ❌ Idempotent / transactional producer (planned, post-1.0) - ❌ KIP-848 new rebalance protocol (planned, post-1.0) - ❌ KIP-368 proactive SASL re-authentication on token expiry (see AUTH.md § Token expiry behaviour for the current reconnect-driven behaviour) - ⚠️ Kafka 4.0 compatibility tracked in #497 📚 Documentation - HexDocs: http://hexdocs.pm/kafka ex/ - GitHub: https://github.com/kafkaex/kafka ex/ - Authentication: AUTH.md - Contributing: CONTRIBUTING.md Table of Contents - Features - Quick Start - Configuration - Usage - Basic Producer/Consumer - Consumer Groups - Metadata & Offsets - Topic Management - Compression - Authentication (SASL) - Telemetry & Observability - Error Handling & Resilience - Testing - Contributing Features KafkaEx v1.0 uses Kayrock for Kafka protocol serialization with automatic API version negotiation —no manual version configuration needed. Core Capabilities - ✅ Producer - Single and batch message production with timestamps and headers - ✅ Consum","default_branch":null,"files":null,"tree":[],"storefront":"/r/kafkaex","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/kafkaex/kafka_ex/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}