You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/06/02 08:58:25 UTC
[rocketmq-connect] 08/10: update README.md
This is an automated email from the ASF dual-hosted git repository.
yukon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 090bddc1c0ba50e7fb0608baeacef0c6768ac3ce
Author: zhaohai <zh...@126.com>
AuthorDate: Thu Jun 2 08:32:00 2022 +0800
update README.md
---
connectors/aliyun/rocketmq-connect-eventbridge/README.md | 7 ++++---
.../connect/eventbridge/sink/EventBridgeSinkConnector.java | 5 ++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/connectors/aliyun/rocketmq-connect-eventbridge/README.md b/connectors/aliyun/rocketmq-connect-eventbridge/README.md
index 8e5ab33..6aec62f 100644
--- a/connectors/aliyun/rocketmq-connect-eventbridge/README.md
+++ b/connectors/aliyun/rocketmq-connect-eventbridge/README.md
@@ -39,11 +39,12 @@ http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-eventbridge-connector
| KEY | TYPE | Must be filled | Description | Example
|------------------------|---------|----------------|----------------------------------|--|
-|stsEndpoint | String | YES | STS endpoint | xxxx|
+|stsEndpoint | String | NO | STS endpoint | xxxx|
+|accountEndpoint | String | YES | 阿里云授信账号 endpoint | xxxx|
|accessKeyId | String | YES | 阿里云授信账号的AK | xxxx |
|accessKeySecret | String | YES | 阿里云授信账号的SK | xxx |
-|roleArn | String | YES | 要扮演的RAM角色ARN。 该角色是可信实体为阿里云账号类型的RAM角色 | xxxx |
-|roleSessionName | String | YES | 角色会话名称。 该参数为用户自定义参数。通常设置为调用该API的用户身份 | 用户名 |
+|roleArn | String | NO | 要扮演的RAM角色ARN。 该角色是可信实体为阿里云账号类型的RAM角色 | xxxx |
+|roleSessionName | String | NO | 角色会话名称。 该参数为用户自定义参数。通常设置为调用该API的用户身份 | 用户名 |
|eventTime | String | NO | 事件产生的时间 | xxxx |
|eventSubject | String | YES | 事件主题 | xxxx |
|eventType | String | YES | 事件类型 | xxxx |
diff --git a/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java b/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java
index 76899ce..254567a 100644
--- a/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java
+++ b/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java
@@ -71,10 +71,9 @@ public class EventBridgeSinkConnector extends SinkConnector {
if (StringUtils.isBlank(config.getString(EventBridgeConstant.ACCESS_KEY_ID))
|| StringUtils.isBlank(config.getString(EventBridgeConstant.ACCESS_KEY_SECRET))
|| StringUtils.isBlank(config.getString(EventBridgeConstant.ACCOUNT_ENDPOINT))
- || StringUtils.isBlank(config.getString(EventBridgeConstant.ROLE_ARN))
- || StringUtils.isBlank(config.getString(EventBridgeConstant.ROLE_SESSION_NAME))
|| StringUtils.isBlank(config.getString(EventBridgeConstant.ALIYUN_EVENT_BUS_NAME))
- || StringUtils.isBlank(config.getString(EventBridgeConstant.STS_ENDPOINT))) {
+ || StringUtils.isBlank(config.getString(EventBridgeConstant.EVENT_SUBJECT))
+ || StringUtils.isBlank(config.getString(EventBridgeConstant.EVENT_TYPE))) {
throw new RuntimeException("EventBridge required parameter is null !");
}
}