public void interruptExecutor() {
            for (Thread thread : this.executorThreads) {
                if (!thread.isInterrupted()) {
                    thread.interrupt();
                }
            }
        }
Returns current thread processing message's TopicPartitionRegInfo.

@since 1.4.6
@return
metamorphosis-client/src/main/java/com/taobao/metamorphosis/client/consumer/SimpleFetchManager.java