kafka内部如何切断提交请求?

How the commit request severed by kafka internally?

当消费者抛出 Offsetcommit 请求时,kafka 代理如何在内部处理它? 哪些线程负责偏移提交请求?

1.All请求消息(包括OffsetCommit请求)首先到达网络队列。
2.然后通过network_thread.
进入请求队列(在kafka broker中) 3.Then IO线程处理它,它进入炼狱,然后发送到响应队列。
4.Finally 网络线程将响应发送给客户端。