Hello,
I was going through the SocketServer code to understand the networking internals of Kafka code base. I see that at some points in the Processor, we mute/unmute certain Kafka channels. These mute/unmute methods seem to be a wrapper to enable/disbale reading new data from respective channels. My question is why do we need this in the first place? >From what I understand, this is needed to process incoming requests in-order. >When we receive a new request from a particular channel, we mute it thus not >reading any new data from it until it is unmuted. Only when the response for >the corresponding request is sent do we unmute it thus resuming data reads >from the channel. Is my understanding correct? If yes, is this the only >purpose this mute/unmute logic serves? Haseeb
