updated for new sarama library changes