client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java (3 lines):
- line 533: //POPTODO think of pop mode orderly implementation later.
- line 973: //POPTODO reuse Executor ?
- line 979: //POPTODO reuse Executor ?
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metrics/TieredStoreMetricsManager.java (2 lines):
- line 203: // TODO: handle exception here
- line 242: // TODO: handle exception
broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConsumerOffsetManagerV2.java (2 lines):
- line 97: // TODO: we have to make a copy here as WriteBatch lacks ByteBuffer API here
- line 137: // TODO: we have to make a copy here as WriteBatch lacks ByteBuffer API here
style/rmq_checkstyle.xml (2 lines):
- line 48:
- line 53:
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java (1 line):
- line 525: // TODO process partial failures of batch message
store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java (1 line):
- line 772: // TODO: check if the delete msg is in the same slot with "the msg to be deleted".
client/src/main/java/org/apache/rocketmq/client/Validators.java (1 line):
- line 130: // TODO: use MixAll.isPropertyValid() when jdk upgrade to 1.8
store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java (1 line):
- line 267: // TODO ugly
store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java (1 line):
- line 123: // TODO: We must ensure every HAConnection represents a different slave
store/src/main/java/org/apache/rocketmq/store/CommitLog.java (1 line):
- line 341: // TODO: Discuss if we need to load more commit-log mapped files into memory.
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java (1 line):
- line 406: // TODO maybe the topic has been deleted.
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java (1 line):
- line 139: // POPTODO order pop consume not implement yet