« Changelog History


kafka_ex v0.10.0 Release Notes

Release Date: 2019-04-11 // about 5 years ago

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

    PRs Included:

    
#343
    #338
    #337
    #335
    #329
    #333
    #331