All relevant changes to mateusjunges/laravel-kafka will be documented here.
- Resolve consumer instance using service container, by @cragonnyunt in #118
- Improved exception handling when a call to
flushreturns an error, by @mateusjunges in #112
- Message consumer Mock, by @gajosu in #107
- Add Batch Support for Message consumer Mock, by @gajosu in #109
- Added consumer contracts, by @mateusjunges in #110
- Add docs for mocking consumers, by @mateusjunges in #111
- Additional option to stop consumer after last message on topic, by @StounhandJ in #103
- Fix docker file by @gajosu in #108
- Fixes Sasl security protocol not being passed to config class. By @gajosu in #106
- Link to the current version documentation fixed by @Elnadrion in #104
- (Documentation) Added missing comas in the class params by @shanginn in #101
- Fixed Passing null to parameter #1 ($string) of type string is deprecated by @elnadrion on #100
- 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.resetto 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-rdkafkav6.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
withBrokerssetter 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
librdkafkav0.11.3 (#4600fdc)
- Cast
auto_committo string on initial consumer options (#f2a6c2b)
- Renamed
AvroencoderExceptiontoAvroSerializerExceptionby @rtuin in #38 - Extend all exceptions from
LaravelKafkaExceptionby @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
createConsumerto use consumer group id from config (#559b467) - Improve consistency with serializers/deserializers naming (#b55772a)
- Added
stopConsumemethod 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
flushcall. (#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
assertPublishedOnTimesto allow usage of callback if the message is null. (#c5b496)
- Added
assertPublishedTimesandassertPublishedOnTimesmethods (#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
publishOnandcreateConsumermethod signatures on kafka facade (#eb66e8e) - Make message argument optional for
assertPublishedandassertPublishedOnmethods (#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_PLAINTEXTandSASL_SSLsecurity 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
$topicsparameter optional onKafka::createConsumermethod. (#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\KafkaConsumerMessageinstance, instead ofRdKafka\Messagedirectly.
Junges\Kafka\Messageclass namespace changed toJunges\Kafka\Message\Message- Method
withMessageKeyrenamed towithBodyKey, onJunges\Kafka\Message\MessageandJunges\Kafka\Producers\ProducerBuilderclasses. (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