@Override
    public ListenerResult listen(WorkflowContext context) throws WorkflowListenerException {
        ClusterResourceProcessForm clusterProcessForm = (ClusterResourceProcessForm) context.getProcessForm();
        log.info("begin to execute ClusterConfigListener for clusterTag={}", clusterProcessForm.getInlongClusterTag());
        String clusterTag = clusterProcessForm.getInlongClusterTag();
        String operator = context.getOperator();
        clusterConfigService.refresh(clusterTag, operator);
        log.info("success to execute ClusterConfigListener for clusterTag={}",
                clusterProcessForm.getInlongClusterTag());
        return ListenerResult.success("success");
    }
Create cluster config listener for cluster tag
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/queue/ClusterConfigListener.java