PHPackages ecotone/kafka - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. [Queues & Workers](/categories/queues) 4. / 5. ecotone/kafka ActiveLibrary[Queues & Workers](/categories/queues) ecotone/kafka ============= Apache Kafka transport for Ecotone asynchronous messaging and Distributed Bus. 1.316.1(3w ago)03.1k↑78.3%1proprietaryPHP Since Nov 2Pushed 3w ago1 watchersCompare [ Source](https://github.com/ecotoneframework/kafka)[ Packagist](https://packagist.org/packages/ecotone/kafka)[ Docs](https://docs.ecotone.tech/)[ GitHub Sponsors](https://github.com/dgafka)[ RSS](/packages/ecotone-kafka/feed)WikiDiscussions main Synced 2d ago READMEChangelogDependencies (40)Versions (132)Used By (1) This is Read Only Repository ============================ [](#this-is-read-only-repository) To contribute make use of [Ecotone-Dev repository](https://github.com/ecotoneframework/ecotone-dev). [ ![](https://github.com/ecotoneframework/ecotone-dev/raw/main/ecotone_small.png?raw=true)](https://ecotone.tech) [![Github Actions](https://github.com/ecotoneFramework/ecotone-dev/actions/workflows/split-testing.yml/badge.svg)](https://github.com/ecotoneFramework/ecotone-dev/actions/workflows/split-testing.yml/badge.svg)[![Latest Stable Version](https://camo.githubusercontent.com/6d3fefd097526666ca1a13fdfa023a2d467c0098ea4f7d560fdea28943d80540/68747470733a2f2f706f7365722e707567782e6f72672f65636f746f6e652f65636f746f6e652f762f737461626c65)](https://packagist.org/packages/ecotone/ecotone)[![License](https://camo.githubusercontent.com/0c825aa97178c47064bc47ec45c9d4148075c860403419e45dbabcb9050d510c/68747470733a2f2f706f7365722e707567782e6f72672f65636f746f6e652f65636f746f6e652f6c6963656e7365)](https://packagist.org/packages/ecotone/ecotone)[![Total Downloads](https://camo.githubusercontent.com/2aec5363d172979490a34009950f2a61290dbb48965361bcbfda9aa28504f7e7/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f64742f65636f746f6e652f65636f746f6e65)](https://packagist.org/packages/ecotone/ecotone)[![PHP Version Require](https://camo.githubusercontent.com/b14eabeef1e6ee3612c8d62386855072c5fdad12affbbd987935c1397ebea214/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f646570656e64656e63792d762f65636f746f6e652f65636f746f6e652f7068702e737667)](https://packagist.org/packages/ecotone/ecotone) **Ecotone is the PHP architecture layer that grows with your system — without rewrites.** From `#[CommandHandler]` on day one, to event sourcing, sagas, outbox, and distributed messaging at scale — one package, same codebase, no forced migrations between growth stages. Declarative PHP 8 attributes on the classes you already have. Apache Kafka transport ---------------------- [](#apache-kafka-transport) Route `#[Asynchronous]` handlers to Kafka topics with partition-aware consumers and the same [retry, outbox, and dead letter semantics](https://docs.ecotone.tech/solutions/unreliable-async-processing) as every other Ecotone transport. Publish from one service and consume in another via the [Distributed Bus](https://ecotone.tech/microservices) — switching transports never changes how your handlers or tests are written. Carries [asynchronous communication](https://ecotone.tech/asynchronous-communication) and [durable workflow](https://ecotone.tech/durable-workflows) execution on the same broker. - **Partitioned consumers** — ordering guarantees per key - **Consumer groups** — scale out horizontally - **Distributed Bus compatible** — cross-service events and commands - **librdkafka-based** — production-proven client Built on top of [librdkafka](https://github.com/confluentinc/librdkafka) via the PHP `rdkafka` extension. Visit [ecotone.tech](https://ecotone.tech) to learn more. > Works with [Symfony](https://docs.ecotone.tech/modules/symfony-ddd-cqrs-event-sourcing), [Laravel](https://docs.ecotone.tech/modules/laravel-ddd-cqrs-event-sourcing), or any PSR-11 framework via [Ecotone Lite](https://docs.ecotone.tech/install-php-service-bus#install-ecotone-lite-no-framework). Getting started --------------- [](#getting-started) See the [quickstart guide](https://docs.ecotone.tech/quick-start) and [reference documentation](https://docs.ecotone.tech). Read more on the [Ecotone Blog](https://blog.ecotone.tech). AI-Ready documentation ---------------------- [](#ai-ready-documentation) Ecotone ships with MCP server, Agentic Skills, and LLMs.txt for any coding agent. See the [AI Integration Guide](https://docs.ecotone.tech/other/ai-integration). Feature requests and issue reporting ------------------------------------ [](#feature-requests-and-issue-reporting) Use [issue tracking system](https://github.com/ecotoneframework/ecotone-dev/issues) for new feature request and bugs. Please verify that it's not already reported by someone else. Contact ------- [](#contact) If you want to talk or ask questions about Ecotone - [**Twitter**](https://twitter.com/EcotonePHP) - **** - [**Community Channel**](https://discord.gg/GwM2BSuXeg) Support Ecotone --------------- [](#support-ecotone) If you want to help building and improving Ecotone consider becoming a sponsor: - [Sponsor Ecotone](https://github.com/sponsors/dgafka) - [Contribute to Ecotone](https://github.com/ecotoneframework/ecotone-dev). Tags ---- [](#tags) PHP, Kafka, Apache Kafka, Ecotone, Message Broker, Distributed Messaging, Event Streaming, Event Driven Architecture ### Health Score 49 — FairBetter than 94% of packages Maintenance95 Actively maintained with recent releases Popularity22 Limited adoption so far Community13 Small or concentrated contributor base Maturity57 Maturing project, gaining track record Bus Factor1 Top contributor holds 99.2% of commits — single point of failure How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~4 days Total 131 Last Release 21d ago ### Community Maintainers ![](https://www.gravatar.com/avatar/1b6139b0dc15c550b22c76954ec6a96ac6c46b4c19b4a3c1e93c2146481e109e?d=identicon)[dgafka](/maintainers/dgafka) --- Top Contributors [![ecotoneframework-bot](https://avatars.githubusercontent.com/u/174240763?v=4)](https://github.com/ecotoneframework-bot "ecotoneframework-bot (130 commits)")[![dgafka](https://avatars.githubusercontent.com/u/6060791?v=4)](https://github.com/dgafka "dgafka (1 commits)") --- Tags streamingkafkaecotonemessage-brokerapache kafkaevent-streamingasync-messagingdistributed-bus ### Code Quality TestsPHPUnit Static AnalysisPHPStan Type Coverage Yes ### Embed Badge ![Health badge](/badges/ecotone-kafka/health.svg) ``` [![Health](https://phpackages.com/badges/ecotone-kafka/health.svg)](https://phpackages.com/packages/ecotone-kafka) ``` ### Alternatives [ecotone/symfony-bundle Ecotone for Symfony — CQRS, Event Sourcing, Sagas, Durable Workflows, and Outbox on top of Symfony Messenger, via PHP attributes. 11249.0k1](/packages/ecotone-symfony-bundle)[ecotone/laravel Ecotone for Laravel — CQRS, Event Sourcing, Sagas, Durable Workflows, and Outbox on top of Laravel Queue, via PHP attributes. 21318.6k3](/packages/ecotone-laravel)[basis-company/nats nats jetstream client for php 206455.7k37](/packages/basis-company-nats)[koco/messenger-kafka Symfony Messenger Kafka Transport 931.2M1](/packages/koco-messenger-kafka)[enqueue/rdkafka Message Queue Kafka Transport 542.6M20](/packages/enqueue-rdkafka)[clue/reactphp-flux Flux, the lightweight stream processor to concurrently do many (but not too many) things at once, built on top of ReactPHP. 59126.4k1](/packages/clue-reactphp-flux) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)