MatrixHB opened a new issue, #3: URL: https://github.com/apache/rocketmq-schema-registry/issues/3
Schema registry uses RocksDB as local cache and uses RocketMQ as remote storage. Now the local cache refresh is implemented by pushConsumer consuming messages from RocketMQ. I found two problems with current code. 1、Using pushConsumer in cluster mode, it must be ensured that each node is a different consumer group, otherwise each node cannot synchronize the complete data. 2、Lack of replay mechanism. When a registry node restart with incomplete local cache, or cold start with empty local cache, we need to pull the complete data from RocketMQ storage to recover the local cache. Therefore, it's better to maintain checkpoint and use pullConsumer to seek specified offset, which is also the suggested way to consume compact topic messages. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
