ROCKETMQ-18 Remove author annotation.

Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: 
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/8ca4657e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/8ca4657e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/8ca4657e

Branch: refs/heads/master
Commit: 8ca4657e15953255450bc5c90673621aeef37132
Parents: f98b121
Author: yukon <yu...@apache.org>
Authored: Wed Dec 28 14:28:13 2016 +0800
Committer: yukon <yu...@apache.org>
Committed: Wed Dec 28 14:28:13 2016 +0800

----------------------------------------------------------------------
 .../main/java/org/apache/rocketmq/broker/BrokerController.java  | 3 ---
 .../src/main/java/org/apache/rocketmq/broker/BrokerStartup.java | 3 ---
 .../org/apache/rocketmq/broker/client/ClientChannelInfo.java    | 3 ---
 .../rocketmq/broker/client/ClientHousekeepingService.java       | 3 ---
 .../org/apache/rocketmq/broker/client/ConsumerGroupInfo.java    | 3 ---
 .../rocketmq/broker/client/ConsumerIdsChangeListener.java       | 3 ---
 .../java/org/apache/rocketmq/broker/client/ConsumerManager.java | 3 ---
 .../broker/client/DefaultConsumerIdsChangeListener.java         | 3 ---
 .../java/org/apache/rocketmq/broker/client/ProducerManager.java | 3 ---
 .../org/apache/rocketmq/broker/client/net/Broker2Client.java    | 3 ---
 .../rocketmq/broker/client/rebalance/RebalanceLockManager.java  | 3 ---
 .../org/apache/rocketmq/broker/latency/BrokerFastFailure.java   | 3 ---
 .../rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java  | 3 ---
 .../java/org/apache/rocketmq/broker/latency/FutureTaskExt.java  | 3 ---
 .../org/apache/rocketmq/broker/longpolling/ManyPullRequest.java | 3 ---
 .../org/apache/rocketmq/broker/longpolling/PullRequest.java     | 3 ---
 .../rocketmq/broker/longpolling/PullRequestHoldService.java     | 3 ---
 .../apache/rocketmq/broker/offset/ConsumerOffsetManager.java    | 3 ---
 .../java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java     | 4 ----
 .../apache/rocketmq/broker/pagecache/ManyMessageTransfer.java   | 3 ---
 .../apache/rocketmq/broker/pagecache/OneMessageTransfer.java    | 3 ---
 .../apache/rocketmq/broker/pagecache/QueryMessageTransfer.java  | 3 ---
 .../rocketmq/broker/processor/AbstractSendMessageProcessor.java | 3 ---
 .../apache/rocketmq/broker/processor/AdminBrokerProcessor.java  | 4 ----
 .../apache/rocketmq/broker/processor/ClientManageProcessor.java | 3 ---
 .../rocketmq/broker/processor/ConsumerManageProcessor.java      | 3 ---
 .../rocketmq/broker/processor/EndTransactionProcessor.java      | 3 ---
 .../rocketmq/broker/processor/ForwardRequestProcessor.java      | 3 ---
 .../apache/rocketmq/broker/processor/PullMessageProcessor.java  | 3 ---
 .../apache/rocketmq/broker/processor/QueryMessageProcessor.java | 3 ---
 .../apache/rocketmq/broker/processor/SendMessageProcessor.java  | 3 ---
 .../java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java | 4 ----
 .../rocketmq/broker/subscription/SubscriptionGroupManager.java  | 3 ---
 .../org/apache/rocketmq/broker/topic/TopicConfigManager.java    | 3 ---
 .../java/org/apache/rocketmq/broker/BrokerControllerTest.java   | 3 ---
 .../test/java/org/apache/rocketmq/broker/BrokerTestHarness.java | 3 ---
 .../java/org/apache/rocketmq/broker/api/SendMessageTest.java    | 3 ---
 .../rocketmq/broker/offset/ConsumerOffsetManagerTest.java       | 3 ---
 .../apache/rocketmq/broker/topic/TopicConfigManagerTest.java    | 3 ---
 .../src/main/java/org/apache/rocketmq/client/ClientConfig.java  | 2 --
 client/src/main/java/org/apache/rocketmq/client/MQAdmin.java    | 1 -
 client/src/main/java/org/apache/rocketmq/client/MQHelper.java   | 3 ---
 .../src/main/java/org/apache/rocketmq/client/QueryResult.java   | 3 ---
 client/src/main/java/org/apache/rocketmq/client/Validators.java | 1 -
 .../java/org/apache/rocketmq/client/admin/MQAdminExtInner.java  | 3 ---
 .../rocketmq/client/consumer/AllocateMessageQueueStrategy.java  | 2 --
 .../apache/rocketmq/client/consumer/DefaultMQPullConsumer.java  | 1 -
 .../apache/rocketmq/client/consumer/DefaultMQPushConsumer.java  | 1 -
 .../java/org/apache/rocketmq/client/consumer/MQConsumer.java    | 1 -
 .../org/apache/rocketmq/client/consumer/MQPullConsumer.java     | 1 -
 .../rocketmq/client/consumer/MQPullConsumerScheduleService.java | 1 -
 .../org/apache/rocketmq/client/consumer/MQPushConsumer.java     | 1 -
 .../apache/rocketmq/client/consumer/MessageQueueListener.java   | 2 --
 .../java/org/apache/rocketmq/client/consumer/PullCallback.java  | 1 -
 .../java/org/apache/rocketmq/client/consumer/PullResult.java    | 3 ---
 .../java/org/apache/rocketmq/client/consumer/PullStatus.java    | 3 ---
 .../client/consumer/listener/ConsumeConcurrentlyContext.java    | 1 -
 .../client/consumer/listener/ConsumeConcurrentlyStatus.java     | 3 ---
 .../client/consumer/listener/ConsumeOrderlyContext.java         | 1 -
 .../rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java | 3 ---
 .../rocketmq/client/consumer/listener/MessageListener.java      | 1 -
 .../client/consumer/listener/MessageListenerConcurrently.java   | 1 -
 .../client/consumer/listener/MessageListenerOrderly.java        | 1 -
 .../consumer/rebalance/AllocateMessageQueueAveragely.java       | 1 -
 .../rebalance/AllocateMessageQueueAveragelyByCircle.java        | 1 -
 .../client/consumer/rebalance/AllocateMessageQueueByConfig.java | 3 ---
 .../rocketmq/client/consumer/store/LocalFileOffsetStore.java    | 1 -
 .../rocketmq/client/consumer/store/OffsetSerializeWrapper.java  | 1 -
 .../org/apache/rocketmq/client/consumer/store/OffsetStore.java  | 1 -
 .../rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java | 1 -
 .../org/apache/rocketmq/client/exception/MQBrokerException.java | 3 ---
 .../org/apache/rocketmq/client/exception/MQClientException.java | 3 ---
 .../org/apache/rocketmq/client/hook/CheckForbiddenContext.java  | 3 ---
 .../org/apache/rocketmq/client/hook/CheckForbiddenHook.java     | 3 ---
 .../org/apache/rocketmq/client/hook/FilterMessageContext.java   | 3 ---
 .../java/org/apache/rocketmq/client/hook/FilterMessageHook.java | 3 ---
 .../apache/rocketmq/client/impl/ClientRemotingProcessor.java    | 3 ---
 .../java/org/apache/rocketmq/client/impl/CommunicationMode.java | 3 ---
 .../java/org/apache/rocketmq/client/impl/FindBrokerResult.java  | 3 ---
 .../main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java  | 3 ---
 .../java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java   | 3 ---
 .../java/org/apache/rocketmq/client/impl/MQClientManager.java   | 3 ---
 .../client/impl/consumer/ConsumeMessageConcurrentlyService.java | 3 ---
 .../client/impl/consumer/ConsumeMessageOrderlyService.java      | 3 ---
 .../rocketmq/client/impl/consumer/ConsumeMessageService.java    | 3 ---
 .../client/impl/consumer/DefaultMQPullConsumerImpl.java         | 3 ---
 .../client/impl/consumer/DefaultMQPushConsumerImpl.java         | 3 ---
 .../apache/rocketmq/client/impl/consumer/MQConsumerInner.java   | 1 -
 .../apache/rocketmq/client/impl/consumer/MessageQueueLock.java  | 1 -
 .../org/apache/rocketmq/client/impl/consumer/ProcessQueue.java  | 1 -
 .../apache/rocketmq/client/impl/consumer/PullAPIWrapper.java    | 3 ---
 .../rocketmq/client/impl/consumer/PullMessageService.java       | 3 ---
 .../org/apache/rocketmq/client/impl/consumer/PullRequest.java   | 3 ---
 .../org/apache/rocketmq/client/impl/consumer/PullResultExt.java | 3 ---
 .../org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java | 1 -
 .../apache/rocketmq/client/impl/consumer/RebalancePullImpl.java | 3 ---
 .../apache/rocketmq/client/impl/consumer/RebalancePushImpl.java | 3 ---
 .../apache/rocketmq/client/impl/consumer/RebalanceService.java  | 1 -
 .../apache/rocketmq/client/impl/factory/MQClientInstance.java   | 3 ---
 .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java    | 3 ---
 .../apache/rocketmq/client/impl/producer/MQProducerInner.java   | 3 ---
 .../apache/rocketmq/client/impl/producer/TopicPublishInfo.java  | 3 ---
 .../apache/rocketmq/client/latency/LatencyFaultTolerance.java   | 3 ---
 .../rocketmq/client/latency/LatencyFaultToleranceImpl.java      | 3 ---
 .../org/apache/rocketmq/client/latency/MQFaultStrategy.java     | 3 ---
 .../main/java/org/apache/rocketmq/client/log/ClientLogger.java  | 3 ---
 .../org/apache/rocketmq/client/producer/DefaultMQProducer.java  | 3 ---
 .../rocketmq/client/producer/LocalTransactionExecuter.java      | 3 ---
 .../apache/rocketmq/client/producer/LocalTransactionState.java  | 3 ---
 .../java/org/apache/rocketmq/client/producer/MQProducer.java    | 3 ---
 .../apache/rocketmq/client/producer/MessageQueueSelector.java   | 3 ---
 .../java/org/apache/rocketmq/client/producer/SendCallback.java  | 3 ---
 .../java/org/apache/rocketmq/client/producer/SendResult.java    | 3 ---
 .../java/org/apache/rocketmq/client/producer/SendStatus.java    | 3 ---
 .../rocketmq/client/producer/TransactionCheckListener.java      | 3 ---
 .../apache/rocketmq/client/producer/TransactionMQProducer.java  | 3 ---
 .../apache/rocketmq/client/producer/TransactionSendResult.java  | 3 ---
 .../client/producer/selector/SelectMessageQueueByHash.java      | 3 ---
 .../producer/selector/SelectMessageQueueByMachineRoom.java      | 3 ---
 .../client/producer/selector/SelectMessageQueueByRandoom.java   | 3 ---
 .../src/main/java/org/apache/rocketmq/common/BrokerConfig.java  | 3 ---
 .../src/main/java/org/apache/rocketmq/common/ConfigManager.java | 3 ---
 .../src/main/java/org/apache/rocketmq/common/Configuration.java | 3 ---
 .../main/java/org/apache/rocketmq/common/CountDownLatch2.java   | 1 -
 .../src/main/java/org/apache/rocketmq/common/DataVersion.java   | 3 ---
 common/src/main/java/org/apache/rocketmq/common/MQVersion.java  | 3 ---
 common/src/main/java/org/apache/rocketmq/common/MixAll.java     | 3 ---
 common/src/main/java/org/apache/rocketmq/common/Pair.java       | 3 ---
 .../src/main/java/org/apache/rocketmq/common/ServiceState.java  | 3 ---
 .../src/main/java/org/apache/rocketmq/common/ServiceThread.java | 4 ----
 .../src/main/java/org/apache/rocketmq/common/SystemClock.java   | 3 ---
 .../src/main/java/org/apache/rocketmq/common/TopicConfig.java   | 3 ---
 .../main/java/org/apache/rocketmq/common/TopicFilterType.java   | 3 ---
 common/src/main/java/org/apache/rocketmq/common/UtilAll.java    | 3 ---
 .../java/org/apache/rocketmq/common/admin/ConsumeStats.java     | 1 -
 .../java/org/apache/rocketmq/common/admin/OffsetWrapper.java    | 1 -
 .../java/org/apache/rocketmq/common/admin/RollbackStats.java    | 1 -
 .../main/java/org/apache/rocketmq/common/admin/TopicOffset.java | 1 -
 .../java/org/apache/rocketmq/common/admin/TopicStatsTable.java  | 1 -
 .../java/org/apache/rocketmq/common/constant/LoggerName.java    | 3 ---
 .../main/java/org/apache/rocketmq/common/constant/PermName.java | 3 ---
 .../org/apache/rocketmq/common/consumer/ConsumeFromWhere.java   | 1 -
 .../main/java/org/apache/rocketmq/common/filter/FilterAPI.java  | 1 -
 .../src/main/java/org/apache/rocketmq/common/help/FAQUrl.java   | 3 ---
 .../java/org/apache/rocketmq/common/hook/FilterCheckHook.java   | 1 -
 .../main/java/org/apache/rocketmq/common/message/Message.java   | 1 -
 .../java/org/apache/rocketmq/common/message/MessageDecoder.java | 3 ---
 .../java/org/apache/rocketmq/common/message/MessageExt.java     | 3 ---
 .../main/java/org/apache/rocketmq/common/message/MessageId.java | 3 ---
 .../java/org/apache/rocketmq/common/message/MessageQueue.java   | 3 ---
 .../org/apache/rocketmq/common/message/MessageQueueForC.java    | 3 ---
 .../java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java  | 2 --
 .../java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java    | 3 ---
 .../apache/rocketmq/common/namesrv/RegisterBrokerResult.java    | 3 ---
 .../java/org/apache/rocketmq/common/namesrv/TopAddressing.java  | 4 ----
 .../org/apache/rocketmq/common/protocol/MQProtosHelper.java     | 3 ---
 .../org/apache/rocketmq/common/protocol/body/ClusterInfo.java   | 3 ---
 .../org/apache/rocketmq/common/protocol/body/Connection.java    | 3 ---
 .../org/apache/rocketmq/common/protocol/body/ConsumeByWho.java  | 1 -
 .../apache/rocketmq/common/protocol/body/ConsumeStatsList.java  | 3 ---
 .../rocketmq/common/protocol/body/ConsumerConnection.java       | 3 ---
 .../common/protocol/body/ConsumerOffsetSerializeWrapper.java    | 3 ---
 .../rocketmq/common/protocol/body/GetConsumerStatusBody.java    | 3 ---
 .../org/apache/rocketmq/common/protocol/body/GroupList.java     | 1 -
 .../java/org/apache/rocketmq/common/protocol/body/KVTable.java  | 1 -
 .../rocketmq/common/protocol/body/LockBatchRequestBody.java     | 1 -
 .../rocketmq/common/protocol/body/LockBatchResponseBody.java    | 1 -
 .../rocketmq/common/protocol/body/ProducerConnection.java       | 3 ---
 .../rocketmq/common/protocol/body/QueryConsumeTimeSpanBody.java | 3 ---
 .../common/protocol/body/QueryCorrectionOffsetBody.java         | 3 ---
 .../org/apache/rocketmq/common/protocol/body/QueueTimeSpan.java | 3 ---
 .../apache/rocketmq/common/protocol/body/ResetOffsetBody.java   | 1 -
 .../rocketmq/common/protocol/body/SubscriptionGroupWrapper.java | 3 ---
 .../org/apache/rocketmq/common/protocol/body/TopicList.java     | 3 ---
 .../rocketmq/common/protocol/body/UnlockBatchRequestBody.java   | 3 ---
 .../protocol/header/CheckTransactionStateRequestHeader.java     | 3 ---
 .../protocol/header/CheckTransactionStateResponseHeader.java    | 3 ---
 .../common/protocol/header/CloneGroupOffsetRequestHeader.java   | 3 ---
 .../protocol/header/ConsumerSendMsgBackRequestHeader.java       | 1 -
 .../common/protocol/header/CreateTopicRequestHeader.java        | 3 ---
 .../protocol/header/DeleteSubscriptionGroupRequestHeader.java   | 3 ---
 .../common/protocol/header/DeleteTopicRequestHeader.java        | 3 ---
 .../common/protocol/header/EndTransactionRequestHeader.java     | 3 ---
 .../common/protocol/header/EndTransactionResponseHeader.java    | 3 ---
 .../common/protocol/header/GetAllTopicConfigResponseHeader.java | 3 ---
 .../common/protocol/header/GetBrokerConfigResponseHeader.java   | 3 ---
 .../common/protocol/header/GetConsumeStatsRequestHeader.java    | 3 ---
 .../protocol/header/GetConsumerConnectionListRequestHeader.java | 1 -
 .../protocol/header/GetConsumerListByGroupRequestHeader.java    | 3 ---
 .../protocol/header/GetConsumerListByGroupResponseBody.java     | 3 ---
 .../protocol/header/GetConsumerListByGroupResponseHeader.java   | 3 ---
 .../protocol/header/GetConsumerRunningInfoRequestHeader.java    | 3 ---
 .../common/protocol/header/GetConsumerStatusRequestHeader.java  | 1 -
 .../protocol/header/GetEarliestMsgStoretimeRequestHeader.java   | 3 ---
 .../protocol/header/GetEarliestMsgStoretimeResponseHeader.java  | 3 ---
 .../common/protocol/header/GetMaxOffsetRequestHeader.java       | 3 ---
 .../common/protocol/header/GetMaxOffsetResponseHeader.java      | 3 ---
 .../common/protocol/header/GetMinOffsetRequestHeader.java       | 3 ---
 .../common/protocol/header/GetMinOffsetResponseHeader.java      | 3 ---
 .../protocol/header/GetProducerConnectionListRequestHeader.java | 3 ---
 .../common/protocol/header/GetTopicStatsInfoRequestHeader.java  | 1 -
 .../common/protocol/header/GetTopicsByClusterRequestHeader.java | 1 -
 .../protocol/header/NotifyConsumerIdsChangedRequestHeader.java  | 3 ---
 .../common/protocol/header/PullMessageRequestHeader.java        | 3 ---
 .../common/protocol/header/PullMessageResponseHeader.java       | 3 ---
 .../protocol/header/QueryConsumeTimeSpanRequestHeader.java      | 1 -
 .../protocol/header/QueryConsumerOffsetRequestHeader.java       | 3 ---
 .../protocol/header/QueryConsumerOffsetResponseHeader.java      | 3 ---
 .../common/protocol/header/QueryCorrectionOffsetHeader.java     | 1 -
 .../common/protocol/header/QueryMessageRequestHeader.java       | 3 ---
 .../common/protocol/header/QueryMessageResponseHeader.java      | 3 ---
 .../protocol/header/QueryTopicConsumeByWhoRequestHeader.java    | 3 ---
 .../common/protocol/header/ResetOffsetRequestHeader.java        | 1 -
 .../common/protocol/header/SearchOffsetRequestHeader.java       | 3 ---
 .../common/protocol/header/SearchOffsetResponseHeader.java      | 3 ---
 .../common/protocol/header/SendMessageRequestHeader.java        | 3 ---
 .../common/protocol/header/SendMessageRequestHeaderV2.java      | 1 -
 .../common/protocol/header/SendMessageResponseHeader.java       | 3 ---
 .../common/protocol/header/UnregisterClientRequestHeader.java   | 3 ---
 .../common/protocol/header/UnregisterClientResponseHeader.java  | 3 ---
 .../protocol/header/UpdateConsumerOffsetRequestHeader.java      | 3 ---
 .../protocol/header/UpdateConsumerOffsetResponseHeader.java     | 3 ---
 .../common/protocol/header/ViewMessageRequestHeader.java        | 3 ---
 .../common/protocol/header/ViewMessageResponseHeader.java       | 3 ---
 .../protocol/header/namesrv/DeleteKVConfigRequestHeader.java    | 1 -
 .../header/namesrv/DeleteTopicInNamesrvRequestHeader.java       | 1 -
 .../protocol/header/namesrv/GetKVConfigRequestHeader.java       | 1 -
 .../protocol/header/namesrv/GetKVConfigResponseHeader.java      | 1 -
 .../header/namesrv/GetKVListByNamespaceRequestHeader.java       | 1 -
 .../protocol/header/namesrv/GetRouteInfoRequestHeader.java      | 3 ---
 .../protocol/header/namesrv/GetRouteInfoResponseHeader.java     | 3 ---
 .../protocol/header/namesrv/RegisterBrokerRequestHeader.java    | 3 ---
 .../protocol/header/namesrv/RegisterBrokerResponseHeader.java   | 1 -
 .../header/namesrv/RegisterOrderTopicRequestHeader.java         | 3 ---
 .../protocol/header/namesrv/UnRegisterBrokerRequestHeader.java  | 3 ---
 .../header/namesrv/WipeWritePermOfBrokerRequestHeader.java      | 1 -
 .../header/namesrv/WipeWritePermOfBrokerResponseHeader.java     | 1 -
 .../apache/rocketmq/common/protocol/heartbeat/ConsumeType.java  | 3 ---
 .../apache/rocketmq/common/protocol/heartbeat/ConsumerData.java | 3 ---
 .../rocketmq/common/protocol/heartbeat/HeartbeatData.java       | 3 ---
 .../apache/rocketmq/common/protocol/heartbeat/MessageModel.java | 1 -
 .../apache/rocketmq/common/protocol/heartbeat/ProducerData.java | 3 ---
 .../rocketmq/common/protocol/heartbeat/SubscriptionData.java    | 3 ---
 .../org/apache/rocketmq/common/protocol/route/BrokerData.java   | 1 -
 .../apache/rocketmq/common/protocol/route/TopicRouteData.java   | 3 ---
 .../org/apache/rocketmq/common/queue/ConcurrentTreeMap.java     | 1 -
 .../main/java/org/apache/rocketmq/common/queue/RoundQueue.java  | 1 -
 .../rocketmq/common/subscription/SubscriptionGroupConfig.java   | 3 ---
 .../java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java | 3 ---
 .../java/org/apache/rocketmq/common/sysflag/PullSysFlag.java    | 3 ---
 .../org/apache/rocketmq/common/sysflag/SubscriptionSysFlag.java | 3 ---
 .../java/org/apache/rocketmq/common/sysflag/TopicSysFlag.java   | 1 -
 .../main/java/org/apache/rocketmq/common/utils/IOTinyUtils.java | 3 ---
 common/src/test/java/org/apache/rocketmq/common/MixAllTest.java | 3 ---
 .../java/org/apache/rocketmq/common/filter/FilterAPITest.java   | 1 -
 .../org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java     | 3 ---
 .../java/org/apache/rocketmq/filtersrv/FiltersrvController.java | 3 ---
 .../java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java    | 3 ---
 .../rocketmq/filtersrv/processor/DefaultRequestProcessor.java   | 3 ---
 .../java/org/apache/rocketmq/namesrv/NamesrvController.java     | 3 ---
 .../main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java   | 3 ---
 .../org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java   | 3 ---
 .../rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java     | 3 ---
 .../rocketmq/namesrv/processor/ClusterTestRequestProcessor.java | 3 ---
 .../rocketmq/namesrv/processor/DefaultRequestProcessor.java     | 3 ---
 .../rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java   | 3 ---
 .../org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java | 3 ---
 .../java/org/apache/rocketmq/remoting/ChannelEventListener.java | 1 -
 .../java/org/apache/rocketmq/remoting/CommandCustomHeader.java  | 3 ---
 .../main/java/org/apache/rocketmq/remoting/InvokeCallback.java  | 1 -
 .../main/java/org/apache/rocketmq/remoting/RemotingClient.java  | 1 -
 .../main/java/org/apache/rocketmq/remoting/RemotingServer.java  | 1 -
 .../java/org/apache/rocketmq/remoting/annotation/CFNotNull.java | 3 ---
 .../org/apache/rocketmq/remoting/annotation/CFNullable.java     | 3 ---
 .../src/main/java/org/apache/rocketmq/remoting/common/Pair.java | 3 ---
 .../org/apache/rocketmq/remoting/common/RemotingHelper.java     | 3 ---
 .../java/org/apache/rocketmq/remoting/common/RemotingUtil.java  | 3 ---
 .../rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java      | 3 ---
 .../java/org/apache/rocketmq/remoting/common/ServiceThread.java | 1 -
 .../rocketmq/remoting/exception/RemotingCommandException.java   | 3 ---
 .../rocketmq/remoting/exception/RemotingConnectException.java   | 3 ---
 .../apache/rocketmq/remoting/exception/RemotingException.java   | 3 ---
 .../remoting/exception/RemotingSendRequestException.java        | 3 ---
 .../rocketmq/remoting/exception/RemotingTimeoutException.java   | 3 ---
 .../remoting/exception/RemotingTooMuchRequestException.java     | 3 ---
 .../org/apache/rocketmq/remoting/netty/NettyClientConfig.java   | 1 -
 .../java/org/apache/rocketmq/remoting/netty/NettyDecoder.java   | 1 -
 .../java/org/apache/rocketmq/remoting/netty/NettyEncoder.java   | 1 -
 .../java/org/apache/rocketmq/remoting/netty/NettyEvent.java     | 3 ---
 .../java/org/apache/rocketmq/remoting/netty/NettyEventType.java | 1 -
 .../apache/rocketmq/remoting/netty/NettyRemotingAbstract.java   | 3 ---
 .../org/apache/rocketmq/remoting/netty/NettyRemotingClient.java | 3 ---
 .../apache/rocketmq/remoting/netty/NettyRequestProcessor.java   | 1 -
 .../org/apache/rocketmq/remoting/netty/NettyServerConfig.java   | 1 -
 .../java/org/apache/rocketmq/remoting/netty/ResponseFuture.java | 3 ---
 .../org/apache/rocketmq/remoting/protocol/RemotingCommand.java  | 3 ---
 .../apache/rocketmq/remoting/protocol/RemotingCommandType.java  | 1 -
 .../apache/rocketmq/remoting/protocol/RemotingSerializable.java | 1 -
 .../apache/rocketmq/remoting/protocol/RocketMQSerializable.java | 1 -
 .../src/test/java/org/apache/rocketmq/remoting/MixTest.java     | 3 ---
 .../test/java/org/apache/rocketmq/remoting/NettyRPCTest.java    | 3 ---
 .../java/org/apache/rocketmq/subclass/TestSubClassAuto.java     | 3 ---
 .../org/apache/rocketmq/store/AllocateMappedFileService.java    | 1 -
 .../java/org/apache/rocketmq/store/AppendMessageCallback.java   | 1 -
 .../java/org/apache/rocketmq/store/AppendMessageResult.java     | 1 -
 .../java/org/apache/rocketmq/store/AppendMessageStatus.java     | 1 -
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java    | 1 -
 store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java | 3 ---
 .../java/org/apache/rocketmq/store/DefaultMessageFilter.java    | 3 ---
 .../java/org/apache/rocketmq/store/DefaultMessageStore.java     | 3 ---
 .../main/java/org/apache/rocketmq/store/DispatchRequest.java    | 3 ---
 .../main/java/org/apache/rocketmq/store/GetMessageResult.java   | 3 ---
 .../main/java/org/apache/rocketmq/store/GetMessageStatus.java   | 3 ---
 store/src/main/java/org/apache/rocketmq/store/MappedFile.java   | 3 ---
 .../main/java/org/apache/rocketmq/store/MappedFileQueue.java    | 3 ---
 .../java/org/apache/rocketmq/store/MessageExtBrokerInner.java   | 3 ---
 .../src/main/java/org/apache/rocketmq/store/MessageFilter.java  | 3 ---
 store/src/main/java/org/apache/rocketmq/store/MessageStore.java | 3 ---
 .../main/java/org/apache/rocketmq/store/PutMessageResult.java   | 3 ---
 .../main/java/org/apache/rocketmq/store/PutMessageStatus.java   | 3 ---
 .../main/java/org/apache/rocketmq/store/QueryMessageResult.java | 3 ---
 .../main/java/org/apache/rocketmq/store/ReferenceResource.java  | 3 ---
 store/src/main/java/org/apache/rocketmq/store/RunningFlags.java | 3 ---
 .../org/apache/rocketmq/store/SelectMappedBufferResult.java     | 3 ---
 .../main/java/org/apache/rocketmq/store/StoreCheckpoint.java    | 3 ---
 .../main/java/org/apache/rocketmq/store/StoreStatsService.java  | 3 ---
 store/src/main/java/org/apache/rocketmq/store/StoreUtil.java    | 1 -
 .../main/java/org/apache/rocketmq/store/TransientStorePool.java | 3 ---
 .../main/java/org/apache/rocketmq/store/config/BrokerRole.java  | 3 ---
 .../java/org/apache/rocketmq/store/config/FlushDiskType.java    | 3 ---
 .../org/apache/rocketmq/store/config/MessageStoreConfig.java    | 4 ----
 .../main/java/org/apache/rocketmq/store/ha/HAConnection.java    | 5 -----
 store/src/main/java/org/apache/rocketmq/store/ha/HAService.java | 3 ---
 .../java/org/apache/rocketmq/store/ha/WaitNotifyObject.java     | 3 ---
 .../main/java/org/apache/rocketmq/store/index/IndexFile.java    | 3 ---
 .../main/java/org/apache/rocketmq/store/index/IndexHeader.java  | 1 -
 .../main/java/org/apache/rocketmq/store/index/IndexService.java | 3 ---
 .../java/org/apache/rocketmq/store/index/QueryOffsetResult.java | 3 ---
 .../rocketmq/store/schedule/DelayOffsetSerializeWrapper.java    | 1 -
 .../apache/rocketmq/store/schedule/ScheduleMessageService.java  | 1 -
 .../main/java/org/apache/rocketmq/store/stats/BrokerStats.java  | 3 ---
 .../java/org/apache/rocketmq/store/DefaultMessageStoreTest.java | 3 ---
 .../java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java | 3 ---
 .../org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java  | 3 ---
 .../java/org/apache/rocketmq/tools/command/CommandUtil.java     | 3 ---
 .../java/org/apache/rocketmq/tools/command/MQAdminStartup.java  | 3 ---
 .../main/java/org/apache/rocketmq/tools/command/SubCommand.java | 3 ---
 .../tools/command/broker/BrokerConsumeStatsSubCommad.java       | 3 ---
 .../rocketmq/tools/command/broker/BrokerStatusSubCommand.java   | 3 ---
 .../rocketmq/tools/command/broker/CleanExpiredCQSubCommand.java | 3 ---
 .../rocketmq/tools/command/broker/CleanUnusedTopicCommand.java  | 3 ---
 .../rocketmq/tools/command/broker/GetBrokerConfigCommand.java   | 3 ---
 .../rocketmq/tools/command/broker/SendMsgStatusCommand.java     | 3 ---
 .../tools/command/broker/UpdateBrokerConfigSubCommand.java      | 3 ---
 .../rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java | 3 ---
 .../rocketmq/tools/command/cluster/ClusterListSubCommand.java   | 3 ---
 .../tools/command/connection/ConsumerConnectionSubCommand.java  | 3 ---
 .../tools/command/connection/ProducerConnectionSubCommand.java  | 3 ---
 .../tools/command/consumer/ConsumerProgressSubCommand.java      | 3 ---
 .../tools/command/consumer/ConsumerStatusSubCommand.java        | 3 ---
 .../rocketmq/tools/command/consumer/ConsumerSubCommand.java     | 3 ---
 .../tools/command/consumer/DeleteSubscriptionGroupCommand.java  | 3 ---
 .../tools/command/consumer/StartMonitoringSubCommand.java       | 3 ---
 .../tools/command/consumer/UpdateSubGroupSubCommand.java        | 3 ---
 .../rocketmq/tools/command/message/PrintMessageSubCommand.java  | 3 ---
 .../rocketmq/tools/command/message/QueryMsgByIdSubCommand.java  | 3 ---
 .../rocketmq/tools/command/message/QueryMsgByKeySubCommand.java | 1 -
 .../tools/command/message/QueryMsgByOffsetSubCommand.java       | 3 ---
 .../rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java   | 1 -
 .../rocketmq/tools/command/namesrv/GetNamesrvConfigCommand.java | 3 ---
 .../rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java   | 1 -
 .../tools/command/namesrv/UpdateNamesrvConfigCommand.java       | 3 ---
 .../rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java | 3 ---
 .../tools/command/offset/ResetOffsetByTimeOldCommand.java       | 1 -
 .../rocketmq/tools/command/topic/DeleteTopicSubCommand.java     | 1 -
 .../rocketmq/tools/command/topic/TopicClusterSubCommand.java    | 1 -
 .../rocketmq/tools/command/topic/TopicListSubCommand.java       | 1 -
 .../rocketmq/tools/command/topic/TopicRouteSubCommand.java      | 1 -
 .../rocketmq/tools/command/topic/TopicStatusSubCommand.java     | 1 -
 .../rocketmq/tools/command/topic/UpdateOrderConfCommand.java    | 1 -
 .../rocketmq/tools/command/topic/UpdateTopicSubCommand.java     | 3 ---
 381 files changed, 953 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java 
b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
index 869e4ab..8e973ac 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -63,9 +63,6 @@ import java.util.Map;
 import java.util.concurrent.*;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class BrokerController {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final Logger LOG_PROTECTION = 
LoggerFactory.getLogger(LoggerName.PROTECTION_LOGGER_NAME);

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java 
b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
index 2882d2d..86091c4 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
@@ -44,9 +44,6 @@ import java.util.Properties;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class BrokerStartup {
     public static Properties properties = null;
     public static CommandLine commandLine = null;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
index 8144b48..a994503 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
@@ -20,9 +20,6 @@ import org.apache.rocketmq.remoting.protocol.LanguageCode;
 import io.netty.channel.Channel;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ClientChannelInfo {
     private final Channel channel;
     private final String clientId;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
index 2842bd6..856ce72 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
@@ -29,9 +29,6 @@ import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ClientHousekeepingService implements ChannelEventListener {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
index 6265d43..d5b056e 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
@@ -33,9 +33,6 @@ import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ConsumerGroupInfo {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final String groupName;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
index d580b26..368582a 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
@@ -21,9 +21,6 @@ import io.netty.channel.Channel;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public interface ConsumerIdsChangeListener {
     void consumerIdsChanged(final String group, final List<Channel> channels);
 }

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
index a9490a6..95ed478 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
@@ -34,9 +34,6 @@ import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ConsumerManager {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final long CHANNEL_EXPIRED_TIMEOUT = 1000 * 120;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
index b974db4..b60fcb3 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
@@ -22,9 +22,6 @@ import io.netty.channel.Channel;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class DefaultConsumerIdsChangeListener implements 
ConsumerIdsChangeListener {
     private final BrokerController brokerController;
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
index 8abb903..0f9954b 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
@@ -32,9 +32,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ProducerManager {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final long LOCK_TIMEOUT_MILLIS = 3000;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java 
b/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
index 70027cd..40eff81 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
@@ -55,9 +55,6 @@ import java.util.Map.Entry;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class Broker2Client {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
index 1fa835c..82ca014 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
@@ -28,9 +28,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class RebalanceLockManager {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.REBALANCE_LOCK_LOGGER_NAME);
     private final static long REBALANCE_LOCK_MAX_LIVE_TIME = 
Long.parseLong(System.getProperty(

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
index 2f4b568..5359368 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
@@ -29,9 +29,6 @@ import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class BrokerFastFailure {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final ScheduledExecutorService scheduledExecutorService = 
Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl(

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
index 9891222..8c4c5e8 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
@@ -19,9 +19,6 @@ package org.apache.rocketmq.broker.latency;
 
 import java.util.concurrent.*;
 
-/**
- * @author vintagew...@apache.org
- */
 public class BrokerFixedThreadPoolExecutor extends ThreadPoolExecutor {
     public BrokerFixedThreadPoolExecutor(final int corePoolSize, final int 
maximumPoolSize, final long keepAliveTime, final TimeUnit unit, final 
BlockingQueue<Runnable> workQueue) {
         super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java 
b/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
index a6a01b2..9454a57 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
@@ -20,9 +20,6 @@ package org.apache.rocketmq.broker.latency;
 import java.util.concurrent.Callable;
 import java.util.concurrent.FutureTask;
 
-/**
- * @author vintagew...@apache.org
- */
 public class FutureTaskExt<V> extends FutureTask<V> {
     private final Runnable runnable;
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
index a6510c7..e261b40 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
@@ -20,9 +20,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ManyPullRequest {
     private final ArrayList<PullRequest> pullRequestList = new 
ArrayList<PullRequest>();
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java 
b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
index b3cf00b..40716f8 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
@@ -21,9 +21,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingCommand;
 import io.netty.channel.Channel;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class PullRequest {
     private final RemotingCommand requestCommand;
     private final Channel clientChannel;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
index d6e4ac9..5182664 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
@@ -30,9 +30,6 @@ import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class PullRequestHoldService extends ServiceThread {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final String TOPIC_QUEUEID_SEPARATOR = "@";

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
index 7188e8d..06ceb36 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
@@ -30,9 +30,6 @@ import java.util.Map.Entry;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ConsumerOffsetManager extends ConfigManager {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final String TOPIC_GROUP_SEPARATOR = "@";

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java 
b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
index 335c105..3d969c4 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
@@ -41,10 +41,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- * @author manhong.yqd
- */
 public class BrokerOuterAPI {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final RemotingClient remotingClient;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
index 9369bd0..e4c3045 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
@@ -26,9 +26,6 @@ import java.nio.channels.WritableByteChannel;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ManyMessageTransfer extends AbstractReferenceCounted implements 
FileRegion {
     private final ByteBuffer byteBufferHeader;
     private final GetMessageResult getMessageResult;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
index ed56be0..3f00ece 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
@@ -25,9 +25,6 @@ import java.nio.ByteBuffer;
 import java.nio.channels.WritableByteChannel;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class OneMessageTransfer extends AbstractReferenceCounted implements 
FileRegion {
     private final ByteBuffer byteBufferHeader;
     private final SelectMappedBufferResult selectMappedBufferResult;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
index ec51508..146770a 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
@@ -26,9 +26,6 @@ import java.nio.channels.WritableByteChannel;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class QueryMessageTransfer extends AbstractReferenceCounted implements 
FileRegion {
     private final ByteBuffer byteBufferHeader;
     private final QueryMessageResult queryMessageResult;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
index 8a285e8..f04e86c 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
@@ -53,9 +53,6 @@ import java.util.Map;
 import java.util.Random;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public abstract class AbstractSendMessageProcessor implements 
NettyRequestProcessor {
     protected static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index 4588d2d..d2d4bc7 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -61,10 +61,6 @@ import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagew...@apache.org
- * @author manhong.yqd
- */
 public class AdminBrokerProcessor implements NettyRequestProcessor {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
index c7b2972..62de995 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
@@ -39,9 +39,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ClientManageProcessor implements NettyRequestProcessor {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
index ef15589..c0c43e0 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
@@ -33,9 +33,6 @@ import org.slf4j.LoggerFactory;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ConsumerManageProcessor implements NettyRequestProcessor {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
index d86d03b..c493c70 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
@@ -38,9 +38,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class EndTransactionProcessor implements NettyRequestProcessor {
     private static final Logger LOGGER = 
LoggerFactory.getLogger(LoggerName.TRANSACTION_LOGGER_NAME);
     private final BrokerController brokerController;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
index 781bd69..67e55a4 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
@@ -25,9 +25,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class ForwardRequestProcessor implements NettyRequestProcessor {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
index 7625d21..041037f 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
@@ -57,9 +57,6 @@ import java.nio.ByteBuffer;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class PullMessageProcessor implements NettyRequestProcessor {
     private static final Logger LOG = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
index 5c60255..0b6b775 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
@@ -39,9 +39,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class QueryMessageProcessor implements NettyRequestProcessor {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
index 5cebd0e..6002df2 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -48,9 +48,6 @@ import java.net.SocketAddress;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class SendMessageProcessor extends AbstractSendMessageProcessor 
implements NettyRequestProcessor {
 
     private List<ConsumeMessageHook> consumeMessageHookList;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java 
b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
index 049c07d..2db2317 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
@@ -30,10 +30,6 @@ import org.slf4j.LoggerFactory;
 import java.io.IOException;
 
 
-/**
- * @author vintagew...@apache.org
- * @author manhong.yqd
- */
 public class SlaveSynchronize {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
index c4432fa..7865bc7 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
@@ -33,9 +33,6 @@ import java.util.Map.Entry;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class SubscriptionGroupManager extends ConfigManager {
     private static final Logger log = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
----------------------------------------------------------------------
diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java 
b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
index 26a898c..9e14332 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
@@ -42,9 +42,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class TopicConfigManager extends ConfigManager {
     private static final Logger LOG = 
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final long LOCK_TIMEOUT_MILLIS = 3000;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
----------------------------------------------------------------------
diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java 
b/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
index 79f82a6..6e7b9b0 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
@@ -26,9 +26,6 @@ import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-/**
- * @author shtykh_roman
- */
 public class BrokerControllerTest {
     protected Logger logger = 
LoggerFactory.getLogger(BrokerControllerTest.class);
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
----------------------------------------------------------------------
diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java 
b/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
index cbc041f..4fd7a5b 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
@@ -33,9 +33,6 @@ import org.slf4j.LoggerFactory;
 import java.io.File;
 import java.util.Random;
 
-/**
- * @author zander
- */
 public class BrokerTestHarness {
 
     protected BrokerController brokerController = null;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
----------------------------------------------------------------------
diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java 
b/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
index 79013af..0ff589d 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
@@ -39,9 +39,6 @@ import org.junit.Test;
 import static org.junit.Assert.*;
 
 
-/**
- * @author zander
- */
 public class SendMessageTest extends BrokerTestHarness{
 
     MQClientAPIImpl client = new MQClientAPIImpl(new NettyClientConfig(), 
null, null, new ClientConfig());

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
----------------------------------------------------------------------
diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
 
b/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
index 8063ff9..d6be5fb 100644
--- 
a/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
+++ 
b/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
@@ -26,9 +26,6 @@ import org.junit.Test;
 import static org.junit.Assert.assertEquals;
 
 
-/**
- * @author zander
- */
 public class ConsumerOffsetManagerTest extends BrokerTestHarness {
 
     @Test

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
----------------------------------------------------------------------
diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
 
b/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
index e199f8d..ab9ab6f 100644
--- 
a/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
+++ 
b/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
@@ -28,9 +28,6 @@ import org.junit.Test;
 import static org.junit.Assert.*;
 
 
-/**
- * @author zander
- */
 public class TopicConfigManagerTest extends BrokerTestHarness {
     @Test
     public void testFlushTopicConfig() throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java 
b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
index b4cd41c..8afca13 100644
--- a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
+++ b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
@@ -24,8 +24,6 @@ import org.apache.rocketmq.remoting.common.RemotingUtil;
 /**
  * Client Common configuration
  *
- * @author vintagew...@apache.org
- * @author vongosl...@apache.org
  */
 public class ClientConfig {
     public static final String SEND_MESSAGE_WITH_VIP_CHANNEL_PROPERTY = 
"com.rocketmq.sendMessageWithVIPChannel";

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java 
b/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
index f350073..6596855 100644
--- a/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
+++ b/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
@@ -26,7 +26,6 @@ import 
org.apache.rocketmq.remoting.exception.RemotingException;
 /**
  * Base interface for MQ management
  *
- * @author vintagew...@apache.org
  */
 public interface MQAdmin {
     /**

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/MQHelper.java 
b/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
index efca00f..b4ddb08 100644
--- a/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
+++ b/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
@@ -26,9 +26,6 @@ import java.util.Set;
 import java.util.TreeSet;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class MQHelper {
     public static void resetOffsetByTimestamp(
             final MessageModel messageModel,

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/QueryResult.java 
b/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
index 16f0f83..af3649b 100644
--- a/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
+++ b/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
@@ -21,9 +21,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class QueryResult {
     private final long indexLastUpdateTimestamp;
     private final List<MessageExt> messageList;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/Validators.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/Validators.java 
b/client/src/main/java/org/apache/rocketmq/client/Validators.java
index e977d44..92fc53b 100644
--- a/client/src/main/java/org/apache/rocketmq/client/Validators.java
+++ b/client/src/main/java/org/apache/rocketmq/client/Validators.java
@@ -31,7 +31,6 @@ import java.util.regex.Pattern;
 /**
  * Common Validator
  *
- * @author manhong.yqd
  */
 public class Validators {
     public static final String VALID_PATTERN_STR = "^[%|a-zA-Z0-9_-]+$";

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java 
b/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
index 2cc0f2c..bc4ca6c 100644
--- a/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
+++ b/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.admin;
 
-/**
- * @author vintagew...@apache.org
- */
 public interface MQAdminExtInner {
 
 }

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
index 9fb2c48..81a71e4 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
@@ -24,8 +24,6 @@ import java.util.List;
 /**
  * Strategy Algorithm for message allocating between consumers
  *
- * @author vintagew...@apache.org
- * @author vongosl...@apache.org
  */
 public interface AllocateMessageQueueStrategy {
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
index aac4207..156b3d0 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
@@ -38,7 +38,6 @@ import java.util.Set;
 /**
  * Default pulling consumer
  *
- * @author vintagew...@apache.org
  */
 public class DefaultMQPullConsumer extends ClientConfig implements 
MQPullConsumer {
     protected final transient DefaultMQPullConsumerImpl 
defaultMQPullConsumerImpl;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
index 2575827..228e075 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
@@ -44,7 +44,6 @@ import java.util.Set;
 /**
  * Wrapped push consumer.in fact,it works as remarkable as the pull consumer
  *
- * @author vintagew...@apache.org
  */
 public class DefaultMQPushConsumer extends ClientConfig implements 
MQPushConsumer {
     protected final transient DefaultMQPushConsumerImpl 
defaultMQPushConsumerImpl;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
index 6d5f7da..9d9c72b 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
@@ -29,7 +29,6 @@ import java.util.Set;
 /**
  * Message queue consumer interface
  *
- * @author vintagew...@apache.org
  */
 public interface MQConsumer extends MQAdmin {
     /**

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
index 036fca2..2335e3d 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
@@ -28,7 +28,6 @@ import java.util.Set;
 /**
  * Pulling consumer interface
  *
- * @author vintagew...@apache.org
  */
 public interface MQPullConsumer extends MQConsumer {
     /**

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
index 5a36ce6..da8ffb5 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
@@ -34,7 +34,6 @@ import java.util.concurrent.TimeUnit;
 /**
  * Schedule service for pull consumer
  *
- * @author vintagew...@apache.org
  */
 public class MQPullConsumerScheduleService {
     private final Logger log = ClientLogger.getLog();

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
index 76f7cea..b04956c 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
@@ -25,7 +25,6 @@ import org.apache.rocketmq.client.exception.MQClientException;
 /**
  * Push consumer
  *
- * @author vintagew...@apache.org
  */
 public interface MQPushConsumer extends MQConsumer {
     /**

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
index 5d50252..7a08348 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
@@ -24,8 +24,6 @@ import java.util.Set;
 /**
  * A MessageQueueListener is implemented by the application and may be 
specified when a message queue changed
  *
- * @author vintagew...@apache.org
- * @author vongosl...@apache.org
  */
 public interface MessageQueueListener {
     /**

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java 
b/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
index 508050d..cf554c4 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
@@ -19,7 +19,6 @@ package org.apache.rocketmq.client.consumer;
 /**
  * Async message pulling interface
  *
- * @author vintagew...@apache.org
  */
 public interface PullCallback {
     void onSuccess(final PullResult pullResult);

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java 
b/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
index 4bd9a78..1cb23ce 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
@@ -21,9 +21,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class PullResult {
     private final PullStatus pullStatus;
     private final long nextBeginOffset;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java 
b/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
index 79378a3..b2a3c8c 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.consumer;
 
-/**
- * @author vintagew...@apache.org
- */
 public enum PullStatus {
     /**
      * Founded

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
index 75fffe8..981ceaf 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
@@ -22,7 +22,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 /**
  * Consumer concurrent consumption context
  *
- * @author vintagew...@apache.org
  */
 public class ConsumeConcurrentlyContext {
     private final MessageQueue messageQueue;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
index 21febbd..cd66699 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.consumer.listener;
 
-/**
- * @author vintagew...@apache.org
- */
 public enum ConsumeConcurrentlyStatus {
     /**
      * Success consumption

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
index cfca174..3c1ef3d 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
@@ -22,7 +22,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 /**
  * Consumer Orderly consumption context
  *
- * @author vintagew...@apache.org
  */
 public class ConsumeOrderlyContext {
     private final MessageQueue messageQueue;

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
index 2783714..2e55d89 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.consumer.listener;
 
-/**
- * @author vintagew...@apache.org
- */
 public enum ConsumeOrderlyStatus {
     /**
      * Success consumption

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
index 9148b33..5d05452 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
@@ -19,7 +19,6 @@ package org.apache.rocketmq.client.consumer.listener;
 /**
  * A MessageListener object is used to receive asynchronously delivered 
messages.
  *
- * @author vintagew...@apache.org
  */
 public interface MessageListener {
 }

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
index 1c807ce..1c59ef7 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
@@ -24,7 +24,6 @@ import java.util.List;
 /**
  * A MessageListenerConcurrently object is used to receive asynchronously 
delivered messages concurrently
  *
- * @author vintagew...@apache.org
  */
 public interface MessageListenerConcurrently extends MessageListener {
     /**

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
index 1efd19f..5de976f 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
@@ -24,7 +24,6 @@ import java.util.List;
 /**
  * A MessageListenerConcurrently object is used to receive asynchronously 
delivered messages orderly.one queue,one thread
  *
- * @author vintagew...@apache.org
  */
 public interface MessageListenerOrderly extends MessageListener {
     /**

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
index 747df83..218f659 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
@@ -28,7 +28,6 @@ import java.util.List;
 /**
  * Average Hashing queue algorithm
  *
- * @author manhong.yqd
  */
 public class AllocateMessageQueueAveragely implements 
AllocateMessageQueueStrategy {
     private final Logger log = ClientLogger.getLog();

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
index d6ab041..d612d4f 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
@@ -28,7 +28,6 @@ import java.util.List;
 /**
  * Cycle average Hashing queue algorithm
  *
- * @author manhong.yqd
  */
 public class AllocateMessageQueueAveragelyByCircle implements 
AllocateMessageQueueStrategy {
     private final Logger log = ClientLogger.getLog();

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
index 8886cb3..c8fe2d1 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
@@ -22,9 +22,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 import java.util.List;
 
 
-/**
- * @author vintagew...@apache.org
- */
 public class AllocateMessageQueueByConfig implements 
AllocateMessageQueueStrategy {
     private List<MessageQueue> messageQueueList;
 

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
index 2e32700..bdaeb58 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
@@ -39,7 +39,6 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Local storage implementation
  *
- * @author vintagew...@apache.org
  */
 public class LocalFileOffsetStore implements OffsetStore {
     public final static String LOCAL_OFFSET_STORE_DIR = System.getProperty(

http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
----------------------------------------------------------------------
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
index b103084..a9fadf2 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
@@ -26,7 +26,6 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Wrapper class for offset serialization
  *
- * @author vintagew...@apache.org
  */
 public class OffsetSerializeWrapper extends RemotingSerializable {
     private ConcurrentHashMap<MessageQueue, AtomicLong> offsetTable =


Reply via email to