public boolean isInMutableState() {
        // Some requests do not require memory, so if we do not know what the current (or future) request is
        // (receive == null) we don't mute. We also don't mute if whatever memory required has already been
        // successfully allocated (if none is required for the currently-being-read request
        // receive.memoryAllocated() is expected to return true)
        if (receive == null || receive.memoryAllocated())
            return false;
        // also cannot mute if underlying transport is not in the ready state
        return transportLayer.ready();
    }
Returns true if this channel has been explicitly muted using {@link KafkaChannel#mute()}
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java