https://github.com/apache/rocketmq-connect/blob/3bfdef8661d9acc420bb7665501651c395461e92/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractStateManagementService.java#L104
