* OffsetCommit and OffsetFetch fixed
* KafkaConnection uses Task.TrySetException instead of Task.SetException to avoid exception when Task got already terminated
* Consumer shouldn't sleep on response received. This is to improve throughput.