NewYour coding agent can read the release notes before it upgrades.Set up the MCP server →
Packagist · #2073 most downloaded on Packagist
A kafka driver for laravel
Last release 5 days ago
29 Sep 2026
Ships fairly regularly
a new release about every 5 weeks
Most releases are documented
notes for 36 of the last 60 stable releases
Nothing withdrawn
no release was ever pulled
5 years old
114 releases · first in 2021
One column per quarter.
Add Logger contract to allow users to implement their own Logger by @remarkusable in #165
Added support for PHP 8.2 by @mateusjunges in #159
- Fixes kafka.php config file
kafka.php config fileAllow to configure sleep timeout when Producer is retrying flush by @mateusjunges in #156
flush by @mateusjunges in #156Filter config options for consumer and producers by @mateusjunges in #151
Make Kafka class usable through interface injection by @mosharaf13 in #150
Nothing published for this version
Fixes batch message processing by @mateusjunges in #143
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Resolve consumer instance using service container, by @cragonnyunt in #118
Improved exception handling when a call to flush returns an error, by @mateusjunges in #112
flush returns an error, by @mateusjunges in #112Message consumer Mock, by @gajosu in #107
Fixes Sasl security protocol not being passed to config class. By @gajosu in #106
Fixed Passing null to parameter #1 ($string) of type string is deprecated by @elnadrion on #100
Fixes error when using SASL_SSL with KafkaConsumerCommmand (issue #96, fixed with #3ea902d)
Fix undefined offset 0 when trying to set Dead Letter Queues without subscribing to any kafka topics (#e06849c)
Fixed Kafka Facade docblock on #93 by @nmfzone
Fix Json Serialize to not serialize the same message twice on #92 by @lukecurtis93
Added support for batch producing and handling batch of messages by @vsvp21 in #86
Return callback result for published messages filter when callback is provided on #87 by @nmfzone
Fixed Kafka Facade docblock on #93 by @nmfzone
Fix Json Serialize to not serialize the same message twice on #92 by @lukecurtis93
Use correct consumer group id config key in consumer command
Added missing auto.offset.reset to the consumer only options array.
auto.offset.reset to the consumer only options array.Fixes CONFWARN on consumer on #75 (issue) with #76 (pull request)
### Fixed - Fixes #69
Add support for ext-rdkafka v6.0
ext-rdkafka v6.0mateusjunges/laravelAllow using sasl with lowercase config keys (#1cc7521)
Included SASL on consumer config when applicable (#5c028bf)
Fixed built in consumer command
Added a withBrokers setter to the consumer api, allowing to set brokers on the run (#6a639ce)
Renamed AvroencoderException to AvroSerializerException by @rtuin in #38
Nothing published for this version
Added message context to committers plus allow to use custom committers (#133a4bb)
Fixed composer.json dependencies. Improve installation process
Allow createConsumer to use consumer group id from config (#559b467)
Added stopConsume method to allow consumer to be gracefully stopped (#db37381)
Fixes exception thrown when kafka cannot complete a flush call. (#ddae8e3)
flush call. (#ddae8e3)Reworked testing framework to properly check what was dispatched (#ec8b3f6)
Fix incorrect message published count (#06c3844)
Fix assertPublishedOnTimes to allow usage of callback if the message is null. (#c5b496)
assertPublishedOnTimes to allow usage of callback if the message is null. (#c5b496)Added assertPublishedTimes and assertPublishedOnTimes methods (#a16a10d)
assertPublishedTimes and assertPublishedOnTimes methods (#a16a10d)publishOn and createConsumer method signatures on kafka facade (#eb66e8e)assertPublished and assertPublishedOn methods (#9ec5eea)Added the security protocol to Sasl class. By default, its used SASL_PLAINTEXT(#f4e62d2)
Allow usage of custom options for producer config (#38ca04)
Added validation to ensure a kafka consumer will not subscribe to a topic if it is already subscribed. (#f1ab25c)
Fixed documentation about message handlers (#c375e10)
Added option to use custom serializers/deserializers with Kafka
Junges\Kafka\Contracts\KafkaConsumerMessage instance, instead of RdKafka\Message directly.Junges\Kafka\Message class namespace changed to Junges\Kafka\Message\MessagewithMessageKey renamed to withBodyKey, on Junges\Kafka\Message\Message and Junges\Kafka\Producers\ProducerBuilder classes. (b41c310)Add documentation to the config file
Fixed argument for assertPublished, used to perform assertions over published messages
assertPublished, used to perform assertions over published messages- Initial release
Your coding agent can read these notes before it upgrades. Set up the MCP server →