Features
- Allow passing in state to a
KafkaEx.GenConsumer by defining a KafkaEx.GenConsumer.init/3 callback. Adds a default implementation of init/3 to ensure backward compatibility. -- @mtrudel
- Support DeleteTopics API for Kafka 0.10+ -- @jbruggem
- Add a default partitioner using murmur2 hashing when key is provided, or random partitioning otherwise. Use the
KafkaEx.Partitioner behaviour to define a different partitioner, and enable it by adding it to the partitioner configuration setting.
Misc
- Thanks to @mjparrott , @clambodile, @soteras for documentation fixes
- Thanks to @gorenje for adding Elixir 1.8 testing and fixing 1.8 compile warnings
PRs Included:
#343
#338
#337
#335
#329
#333
#331
