Changelog

All relevant changes to mateusjunges/laravel-kafka will be documented here.

2021-12-21 v1.5.3

Fixed

• Included SASL on consumer config when applicable (#5c028bf)

2021-12-19 v1.5.2

Fixed

• Fixed built in consumer command (#50)

2021-12-10 v1.5.1

Added

• 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)

Fixed

• Cast auto_commit to string on initial consumer options (#f2a6c2b)

2021-12-08 v1.5.0

Changed

• Renamed AvroencoderException to AvroSerializerException by @rtuin in #38
• Extend all exceptions from LaravelKafkaException by @rtuin in #38

2021-12-08 v1.4.5

Added

• 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)

2021-12-03 v1.4.4

Fixed

• Fixed composer.json dependencies. Improve installation process (#5981907)

2021-12-01 v1.4.3

Added

• Allow createConsumer to use consumer group id from config (#559b467)
• Improve consistency with serializers/deserializers naming (#b55772a)

2021-11-29 v1.4.2

Added

• 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)

2020-11-23 v1.4.1

Fixed

• Fixes exception thrown when kafka cannot complete a flush call. (#ddae8e3)

2021-11-23 v1.4.0

Fixed

• 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)

2021-11-14 v1.3.1

Changed

• Fix assertPublishedOnTimes to allow usage of callback if the message is null. (#c5b496)

2021-11-14 v1.3.0

Added

• Added assertPublishedTimes and assertPublishedOnTimes methods (#a16a10d)

Changed

• 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 and createConsumer method signatures on kafka facade (#eb66e8e)
• Make message argument optional for assertPublished and assertPublishedOn methods (#9ec5eea)

2021-11-08 v1.2.0

Added

• 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 and SASL_SSL security protocols with sasl. (#49e1112)

2021-11-05 v1.1.3

Added

• Allow usage of custom options for producer config (#38ca04)

2021-10-20 v1.1.2

Added

• Added validation to ensure a kafka consumer will not subscribe to a topic if it is already subscribed. (#f1ab25c)

Changed

• Make $topics parameter optional on Kafka::createConsumer method. (#ef7a1a8)

2021-09-28 v1.1.1

Fixed

• Fixed documentation about message handlers (#c375e10)
• Fixed tests to test a message can be consumed using message handlers

2021-09-27 v1.1.0

Added

• 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 of RdKafka\Message directly.

Changed

• Junges\Kafka\Message class namespace changed to Junges\Kafka\Message\Message
• Method withMessageKey renamed to withBodyKey, on Junges\Kafka\Message\Message and Junges\Kafka\Producers\ProducerBuilder classes. (b41c310)

2021-09-25 v1.0.2

Added

• Add documentation to the config file
• Add tag to publish config file

Fixed

• Fix documentation typos #2
• Fix installation docs

2021-09-12 v1.0.1

• Fixed argument for assertPublished, used to perform assertions over published messages
• Add testing documentation

2021-09-12 v1.0.0

• Initial release