use Serializer

Merge pull request #18 from KonstantinCodes/feature/functional-test

Remove Decoder, add Functional Tests

Improve Serializer integration

v0.7

Merge pull request #17 from gennadigennadigennadi/fix/replace-headers…

Make Decoder taggable

Merge pull request #14 from KonstantinCodes/feature/lower-complexity

Simplify Transport

Add KafkaMessageDecoderInterface

This interface allows for more customization, when working with external systems.

Add flushTimeout

Merge pull request #8 from doranych/master

Add flush timeout ms option to KafkaTransport configuration.

Package Upgrades

v0.3

Update composer.json

Optimizations

Merge pull request #3 from andsm/subscribe

Removed re-subscription

Initial Release

Produce & Consume with minimum feature set.