All relevant changes to mateusjunges/laravel-kafka
will be documented here.
- 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
- 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
- Added support for Laravel 9 in the tests pipeline on #88 by @mateusjunges
- 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.
- Fixes CONFWARN on consumer on #75 (issue) with #76 (pull request)
- Fixes Sasl authentication not working #77 (issue) with #78 (pull request)
- Fixes #69
- Add support for
ext-rdkafka
v6.0
- Changed docker image used for tests to
mateusjunges/laravel
- Removed Null Serializer
- Message headers can't be null (#ea9d97f)
- Allow using sasl with lowercase config keys (#1cc7521)
- Included SASL on consumer config when applicable (#5c028bf)
- Fixed built in consumer command (#50)
- Added a
withBrokers
setter to the consumer api, allowing to set brokers on the run (#6a639ce) - Added boolean argument to
withAutoCommit
, which defaults to true (#3ffb226) - Added support for
librdkafka
v0.11.3 (#4600fdc)
- Cast
auto_commit
to string on initial consumer options (#f2a6c2b)
- Renamed
AvroencoderException
toAvroSerializerException
by @rtuin in #38 - Extend all exceptions from
LaravelKafkaException
by @rtuin in #38
- Added message context to committers plus allow to use custom committers (#133a4bb)
- Added retryable handler, allowing to retry message handling and block processing any other message. (#0f9aeee)
- Fixed composer.json dependencies. Improve installation process (#5981907)
- Allow
createConsumer
to use consumer group id from config (#559b467) - Improve consistency with serializers/deserializers naming (#b55772a)
- Added
stopConsume
method to allow consumer to be gracefully stopped (#db37381) - Reduced consumer timeout to a more realistic number, this allows signals to be caught every 2 seconds allowing graceful shutdown (#af1902f)
- Fixes exception thrown when kafka cannot complete a
flush
call. (#ddae8e3)
- Reworked testing framework to properly check what was dispatched (#ec8b3f6)
- Fixed incorrect param ordering on test (#1022799)
- Fixed KafkaFake to store published messages correctly (#4fe6e96)
- Added tests to ensure count of published messages works (#7ea370f)
- Allow using SASL with lowercase config keys. (#ca542e21)
- Fix incorrect message published count (#06c3844)
- Fixed exception thrown when kafka cannot complete a flush call (#9a1fcba)
- Fix
assertPublishedOnTimes
to allow usage of callback if the message is null. (#c5b496)
- Added
assertPublishedTimes
andassertPublishedOnTimes
methods (#a16a10d)
- Make topic name optional. Add method to set topic name when using fake driver (#12dde5, #8f5b25, #f3c8b43, #fe19922)
- Make broker parameter optional (#5625bef, #aa5596c, #c6ad0e9, #5117cd8)
- Allow getTopicName to return null on KafkaMessage contract (#3e6289d)
- Make topicName optional on Message::create() (#7213af9)
- Fix
publishOn
andcreateConsumer
method signatures on kafka facade (#eb66e8e) - Make message argument optional for
assertPublished
andassertPublishedOn
methods (#9ec5eea)
- Added the security protocol to Sasl class. By default, its used
SASL_PLAINTEXT
(#f4e62d2) - Allow usage of SASL with Kafka producers (#04686cc)
- Allow both
SASL_PLAINTEXT
andSASL_SSL
security protocols with sasl. (#49e1112)
- 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)
- Make
$topics
parameter optional onKafka::createConsumer
method. (#ef7a1a8)
- Fixed documentation about message handlers (#c375e10)
- Fixed tests to test a message can be consumed using message handlers
- Added option to use custom serializers/deserializers with Kafka(#5)
- Added default AVRO, Json and Null serializers/deserializers (#5)
- Message handlers now receives a
Junges\Kafka\Contracts\KafkaConsumerMessage
instance, instead ofRdKafka\Message
directly.
Junges\Kafka\Message
class namespace changed toJunges\Kafka\Message\Message
- Method
withMessageKey
renamed towithBodyKey
, onJunges\Kafka\Message\Message
andJunges\Kafka\Producers\ProducerBuilder
classes. (b41c310)
- Add documentation to the config file
- Add tag to publish config file
- Fix documentation typos #2
- Fix installation docs
- Fixed argument for
assertPublished
, used to perform assertions over published messages - Add testing documentation
- Initial release