adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/CreateSinkConnectorRequest.java [50:73]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        super(endpoint);
    }

    @SneakyThrows
    public URI getURI() {
        return new URI(String.format(endpoint + path, name));
    }

    public Map<String, Object> getRequestObject() {
        Map<String, Object> config = Maps.newHashMap();
        config.put("connector-class", connectorClass);
        config.put("connect-topicname", topicName);
        config.put("transforms", String.join(",", transforms.stream()
            .map(TransformRequest::getName)
            .collect(Collectors.toList())));
        transforms.forEach(transform -> {
            transform.getConfig()
                .entrySet()
                .forEach(entry -> {
                    config.put("transforms" + "-" + transform.getName() + "-" + entry.getKey(), entry.getValue());
                });
        });
        config.putAll(connectorConfig);
        return config;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/CreateSourceConnectorRequest.java [46:69]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        super(endpoint);
    }

    @SneakyThrows
    public URI getURI() {
        return new URI(String.format(endpoint + path, name));
    }

    public Map<String, Object> getRequestObject() {
        Map<String, Object> config = Maps.newHashMap();
        config.put("connector-class", connectorClass);
        config.put("connect-topicname", topicName);
        config.put("transforms", String.join(",", transforms.stream()
            .map(TransformRequest::getName)
            .collect(Collectors.toList())));
        transforms.forEach(transform -> {
            transform.getConfig()
                .entrySet()
                .forEach(entry -> {
                    config.put("transforms" + "-" + transform.getName() + "-" + entry.getKey(), entry.getValue());
                });
        });
        config.putAll(connectorConfig);
        return config;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -