All relevant changes to mateusjunges/laravel-kafka will be documented here.
- 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)
- 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