Added
- Added option to use custom serializers/deserializers with Kafka by @mateusjunges(#5)
- Added default AVRO, Json and Null serializers/deserializers by @mateusjunges (#5)
- Message handlers now receives a
Junges\Kafka\Contracts\KafkaConsumerMessageinstance, instead ofRdKafka\Messagedirectly.
Changed
Junges\Kafka\Messageclass namespace changed toJunges\Kafka\Message\Message- Method
withMessageKeyrenamed towithBodyKey, onJunges\Kafka\Message\MessageandJunges\Kafka\Producers\ProducerBuilderclasses. ([b41c310]