Druid Kafka extension to avoid Kafka high level API rebalance issue - View it on GitHub