core/src/main/java/org/apache/rocketmq/schema/registry/core/service/SchemaServiceImpl.java (3 lines):
- line 93: // TODO: add user and ak sk
- line 121: // TODO: async upload to speed up register operation and keep atomic with register
- line 224: // TODO add get last record query
common/src/main/java/org/apache/rocketmq/schema/registry/common/storage/StorageManager.java (3 lines):
- line 89: // TODO 1. string constants
- line 90: // TODO 2. validate
- line 91: // TODO 3. encrypt / decrypt
storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java (3 lines):
- line 101: // TODO setCreateMissingColumnFamilies
- line 286: // TODO: next query on other machine may can't found schema in cache since send is async with receive
- line 392: // TODO: get from rocketmq topic if cache not contain
core/src/main/java/org/apache/rocketmq/schema/registry/core/api/RequestProcessor.java (2 lines):
- line 50: * TODO: 1. add rate limiter and metrics statics
- line 51: * TODO: 2. add async process
style/rmq_checkstyle.xml (2 lines):
- line 43:
- line 48:
core/src/main/java/org/apache/rocketmq/schema/registry/core/dependency/DynamicCompileProvider.java (1 line):
- line 97: // TODO: replace to artifactory-client-java
core/src/main/java/org/apache/rocketmq/schema/registry/core/api/v1/SchemaController.java (1 line):
- line 155: // TODO: support register by sql
common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/SnowFlakeIdGenerator.java (1 line):
- line 51: // TODO: reset time after the limit is exceeded
common/src/main/java/org/apache/rocketmq/schema/registry/common/filter/RequestFilter.java (1 line):
- line 63: // TODO: get request Authorization from http header