Cleanup Kafka protocol implementation code
Drop dependency on ZkUtils