https://github.com/bsm/sarama-cluster