@Override
                            public void run() {
                                Thread currentThread = Thread.currentThread();
                                FetchRequestRunner.this.executorThreads.add(currentThread);
                                try {
                                    FetchRequestRunner.this.receiveMessages(request, it, listener, filter, group);
                                }
                                finally {
                                    FetchRequestRunner.this.executorThreads.remove(currentThread);
                                }
                            }
Returns current thread processing message's TopicPartitionRegInfo.

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