RockteMQ-AI commented on issue #538: URL: https://github.com/apache/rocketmq-connect/issues/538#issuecomment-5487019653
**Issue Evaluation** Category: `question` The `BrokerBasedLog` in `AbstractStateManagementService` is used for persistent state storage of connector/task configurations and offsets. It creates a new instance because the state management service needs its own internal topic for storing metadata, separate from the data topics that connectors process. This is a design choice where each state management service instance maintains its own log for durability and consistency of metadata operations. --- *Automated evaluation by RockteMQ-AI* -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
