Adoption to leffen-kafka-rb gem