登录 注册

kafka_ex

去点 Star
开发者工具
611
Stars
—
Forks
0
Watchers
—
Open Issues
待补全
许可证
Elixir
语言
—
创建时间
最近更新

项目能做什么

Elixir 语言的 Kafka 客户端库。
来源：AI 基于仓库事实生成 · 内容以仓库实际 README 为准

使用说明 查看原始 README 原仓库文档

中文使用说明暂未生成。下面保留原仓库 README 摘录，命令与配置均以原文为准。
原始 README 摘录（英文原文，节选前 3000 字符） 
KafkaEx
========

[![Unit Tests](https://github.com/kafkaex/kafka_ex/actions/workflows/unit-tests.yml/badge.svg)](https://github.com/kafkaex/kafka_ex/actions/workflows/unit-tests.yml)
[![Integration Tests](https://github.com/kafkaex/kafka_ex/actions/workflows/integration-tests.yml/badge.svg)](https://github.com/kafkaex/kafka_ex/actions/workflows/integration-tests.yml)
[![Static Checks](https://github.com/kafkaex/kafka_ex/actions/workflows/static-checks.yml/badge.svg)](https://github.com/kafkaex/kafka_ex/actions/workflows/static-checks.yml)
[![Coverage Status](https://coveralls.io/repos/github/kafkaex/kafka_ex/badge.svg?branch=master)](https://coveralls.io/github/kafkaex/kafka_ex?branch=master)
[![Hex.pm version](https://img.shields.io/hexpm/v/kafka_ex.svg?style=flat-square)](https://hex.pm/packages/kafka_ex)
[![Hex.pm downloads](https://img.shields.io/hexpm/dt/kafka_ex.svg?style=flat-square)](https://hex.pm/packages/kafka_ex)
[![License](https://img.shields.io/hexpm/l/kafka_ex.svg?style=flat-square)](https://hex.pm/packages/kafka_ex)
[![API Docs](https://img.shields.io/badge/api-docs-yellow.svg?style=flat-square)](http://hexdocs.pm/kafka_ex/)

KafkaEx is an Elixir client for [Apache Kafka](http://kafka.apache.org/). KafkaEx requires Elixir 1.14+ and Erlang OTP 24+. Supported Kafka versions: 0.11.0 and newer (see [Supported Kafka Versions](#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 consumer group protocol, opt-in with `group_protocol: :consumer` (Kafka 4.0+; see [Next-generation consumer groups](#next-generation-consumer-groups-kip-848))
- ❌ KIP-368 proactive SASL re-authentication on token expiry (see [AUTH.md § Token expiry behaviour](./AUTH.md#token-expiry-behaviour) for the current reconnect-driven behaviour)
- ⚠️ Kafka 4.0 compatibility tracked in [#497](https://github.com/kafkaex/kafka_ex/issues/497)

## 📚 Documentation

- **HexDocs:** [http://hexdocs.pm/kafka_ex/](http://hexdocs.pm/kafka_ex/)
- **GitHub:** [https://github.com/kafkaex/kafka_ex/](https://github.com/kafkaex/kafka_ex/)
- **Authentication:** [AUTH.md](./AUTH.md)
- **Contributing:** [CONTRIBUTING.md](./CONTRIBUTING.md)

## Table of Contents

- [Features](#features)
- [Quick Start](#quick-start)
- [Configuration](#configuration)
- [Usage](#usage)
  - [Basic Producer/Consumer](#basic-producerconsumer)
  - [Consumer Groups](#consumer-groups)
  - [Next-generation consumer groups (KIP-848)](#next-generation-consumer-groups-kip-848)
  - [Metadata & Offsets](#metadata--offsets)
  - [Topic Management](#topic-management)
  - [Compression](#compression)
- [Authentication (SASL)](#authentication-sasl)
- [Telemetr
阅读完整原文

项目深度分析 AI 生成

企业级企业支持与关键协议定制开发 (Commercial Support & Features)

产品构想针对依赖 Elixir 且使用 Kafka 的重度企业用户，提供带 SLA 的企业支持服务，并针对目前仓库未完成的缺失项（如 Transactional Producer、KIP-368 动态认证、Kafka 4.0 完整适配）进行赞助或合同开发。
核心功能7x24 紧急 Bug 修复响应、Transactional Producer (精确一次投递) 专属扩展包、AWS MSK/OAuth 深度鉴权支持、性能调优审计。
目标用户采用 Elixir 构建金融科技、物联网或实时通信系统的中大型企业工程团队。
难度/周期高 · 3-6 个月 · 成本：极高（需精通 Kafka Wire Protocol、BEAM OTP 容错模型及 Kayrock 序列化库）。
收费模式年度技术支持订阅费（SLA 级别）或专项里程碑功能赞助合同。
竞争风险Elixir 开发者基盘相对小众，且社区内存在替代方案（如 brod 或 Broadway Kafka），企业付费意愿集中在少数重度用户。
依据 已验证事实

KafkaEx 性能监控与 Broadway 流式集成开箱套件 (Telemetry & Pro Kit)

产品构想基于项目现有的 27+ Telemetry 指标，构建针对 PromEx/Grafana 的开箱即用可视化仪表盘扩展，以及为 Elixir Broadway 提供深度优化的生产级高吞吐流处理适配器。
核心功能预配置的 Grafana/PromEx 仪表盘、延迟/堆积报警规则模板、Broadway 流水线高性能消费集成组件包、内存泄露与分区重平衡诊断指南。
目标用户正在将 Elixir 应用部署到生产环境并使用 Prometheus/Grafana 进行可观测性监控的 SRE 和后端工程师。
难度/周期中等 · 1-2 个月 · 成本：低（主要为工程配置、Grafana 仪表盘开发与集成测试成本）。
收费模式商业单次购买 License（类似 Pro UI/Plugin 模式）或 GitHub Sponsors 专属权益包。
竞争风险监控面板与胶水代码容易被开发者自行逆向还原，缺乏足够的代码壁垒。
依据 尚需验证的假设

企业级消息中间件架构与混合云迁移咨询 (Consulting & Migration)

产品构想为传统消息队列（如 RabbitMQ）向 Kafka 迁移或自建 Kafka 迁移至 AWS MSK/Confluent 的 Elixir 团队提供专项迁移与架构重构咨询服务。
核心功能架构评估报告、并发消费模型设计、分区与消费组再平衡性能调优、零停机双写迁移方案制定。
目标用户面临业务扩展瓶颈，需要重构高吞吐事件流架构的初创及中型科技公司 CTO/技术主管。
难度/周期中等 · 按项目交付（2-4 周/单） · 成本：低（主要是资深工程师的时间成本）。
收费模式按人天或按项目固定费用计费的咨询顾问服务费。
竞争风险咨询模式难以标准化和产品化规模扩张，对个人声誉和网络信任度依赖极高。
依据 AI推测
AI 基于仓库公开数据分析生成，含推测成分，不构成收益承诺。
报告会保存到 个人中心

竞品与相似项目 GitHub Search 真实检索

相似项目数据正在完善中，暂不展示（避免误导）

项目优势与风险

技术成熟度创建时间待补全，最近推送 ，发布过 18 个 Release
社区活跃Star 611 / Fork 0 / Issue 0（数据支持，可自行核实）
许可证未检测到（需人工确认）
主要风险上游项目方向可能变化；同赛道竞争者较多（见竞品表）；热度与需求不完全等价

安装与使用

此项目未提供 Docker 镜像，安装步骤以原仓库 README 为准（涉及依赖安装与环境配置，对新手门槛较高）。