Kafka consumer protocol for Erlang