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