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