建立 Amazon EventBridge 管道

若要使用主控台將 Confluent Cloud 串流設定為來源

1. 針對來源，選擇 Confluent Cloud。

2. 針對引導伺服器，輸入您的經紀人的 host:port 對地址。

3. 在主題名稱中，輸入管道將從中讀取的主題名稱。

4. (選用) 針對 VPC，選擇您要的 VPC。然後，針對 VPC 子網路，選擇所需的子網路。針對 VPC 安全群組，請選擇安全群組。

5. 對於身分驗證 - 選用，開啟使用身分驗證並執行下列動作：

   1. 針對驗證方法，請選擇驗證類型。

   2. 針對秘密金鑰，請選擇秘密金鑰。

   如需詳細資訊，請參閱 Confluent 文件中的驗證 Confluent Cloud 資源。

6. (選用) 針對其他設定，請執行下列動作：

   1. 針對起始位置，選擇下列的一或多個選項：

      • 最新：使用碎片中的最新記錄開始讀取串流。

      • 修剪水平線：使用碎片中最後一個未修剪的記錄開始讀取串流。這是碎片中最古老的記錄。

   2. 針對批次大小 - 選用，輸入每個批次的最大記錄數。預設值為 100.

   3. 若為批次視窗 - 選用，請輸入在繼續之前收集記錄的秒數上限。

1. 針對來源，選擇 DynamoDB。

2. 針對 DynamoDB 串流，請選擇您要用作來源的串流。

3. 針對起始位置，選擇下列的一或多個選項：

   • 最新：使用碎片中的最新記錄開始讀取串流。

   • 修剪水平線：使用碎片中最後一個未修剪的記錄開始讀取串流。這是碎片中最古老的記錄。

4. (選用) 針對其他設定，請執行下列動作：

   1. 針對批次大小 - 選用，輸入每個批次的最大記錄數。預設值為 100.

   2. 若為批次視窗 - 選用，請輸入在繼續之前收集記錄的秒數上限。

   3. 針對每個碎片的並行批次 - 選用 ，輸入可同時讀取的相同碎片中的批次數。

   4. 針對部份批次料號失敗時，請選擇下列項目：

      • AUTOMATIC_BISECT：將每個批次減半並分別重試，直到處理完所有記錄或批次中剩下一則失敗訊息為止。

      注意

      如果您沒有選擇 AUTOMATIC_BISECT，您可以傳回特定失敗的記錄，而且只有那些記錄會重試。

若要使用主控台設定 Kinesis 來源

1. 針對來源，選擇 Kinesis。

2. 針對 Kinesis 串流，請選擇您要用作來源的串流。

3. 針對起始位置，選擇下列的一或多個選項：

   • 最新：使用碎片中的最新記錄開始讀取串流。

   • 修剪水平線：使用碎片中最後一個未修剪的記錄開始讀取串流。這是碎片中最古老的記錄。

   • 在時間戳記：從指定的時間開始讀取串流。在時間戳記下，使用 YYYY/MM/DD 和 HH: mm: ss 格式輸入資料和時間。

4. (選用) 針對 Additional settings (其他設定)，執行下列動作：

   1. 針對批次大小 - 選用，輸入每個批次的最大記錄數。預設值為 100.

   2. (選用) 若為批次視窗 - 選用，請輸入在繼續之前收集記錄的秒數上限。

   3. 針對每個碎片的並行批次 - 選用 ，輸入可同時讀取的相同碎片中的批次數。

   4. 針對部份批次料號失敗時，請選擇下列項目：

      • AUTOMATIC_BISECT：將每個批次減半並分別重試，直到處理完所有記錄或批次中剩下一則失敗訊息為止。

      注意

      如果您沒有選擇 AUTOMATIC_BISECT，您可以傳回特定失敗的記錄，而且只有那些記錄會重試。

若要使用主控台設定 Amazon MQ 來源

1. 針對來源，選擇 Amazon MQ。

2. 針對 Amazon MQ 中介，請選擇您要用作來源的串流。

3. 在佇列名稱中，輸入管道將從中讀取的佇列名稱。

4. 針對驗證方法，請選擇基本驗證。

5. 針對秘密金鑰，請選擇秘密金鑰。

6. (選用) 針對其他設定，請執行下列動作：

   1. 針對批次大小 - 選用，輸入每個批次的最大訊息數。預設值為 100.

   2. 若為批次視窗 - 選用，請輸入在繼續之前收集記錄的秒數上限。

若要使用主控台設定 Amazon MSK 來源

1. 針對來源，選擇 Amazon MSK。

2. 針對 Amazon MSK 叢集，選擇要開啟的叢集。

3. 在主題名稱中，輸入管道將從中讀取的主題名稱。

4. (選用) 針對取用者群組 ID，輸入要加入的取用者群組 ID。

5. (選用) 針對驗證 - 選用，請開啟使用驗證並執行下列動作：

   1. 針對驗證方法，選擇您想要的類型。

   2. 針對秘密金鑰，請選擇秘密金鑰。

6. (選用) 針對其他設定，請執行下列動作：

   1. 針對批次大小 - 選用，輸入每個批次的最大記錄數。預設值為 100.

   2. 若為批次視窗 - 選用，請輸入在繼續之前收集記錄的秒數上限。

   3. 針對起始位置，選擇下列的一或多個選項：

      • 最新：使用碎片中最新記錄開始閱讀主題。

      • 修剪水平線：使用碎片中最後一個未修剪的記錄開始讀取主題。這是碎片中最古老的記錄。

        注意

        針對 Apache Kafka，修剪地平線與最早是相同的。

若要使用主控台設定自我管理的 Apache Kafka 來源

1. 針對源，選擇自我管理 Apache Kafka。

2. 針對引導伺服器，輸入您的經紀人的 host:port 對地址。

3. 在主題名稱中，輸入管道將從中讀取的主題名稱。

4. (選用) 針對 VPC，選擇您要的 VPC。然後，針對 VPC 子網路，選擇所需的子網路。針對 VPC 安全群組，請選擇安全群組。

5. (選用) 針對驗證 - 選用，請開啟使用驗證並執行下列動作：

   1. 針對驗證方法，請選擇驗證類型。

   2. 針對秘密金鑰，請選擇秘密金鑰。

6. (選用) 針對其他設定，請執行下列動作：

   1. 針對起始位置，選擇下列的一或多個選項：

      • 最新：使用碎片中的最新記錄開始讀取串流。

      • 修剪水平線：使用碎片中最後一個未修剪的記錄開始讀取串流。這是碎片中最古老的記錄。

   2. 針對批次大小 - 選用，輸入每個批次的最大記錄數。預設值為 100.

   3. 若為批次視窗 - 選用，請輸入在繼續之前收集記錄的秒數上限。

若要使用主控台設定 Amazon SQS 來源

1. 針對來源，選擇 SQS。

2. 針對 SQS 佇列，請選擇要使用的佇列。

3. (選用) 針對其他設定，請執行下列動作：

   1. 針對批次大小 - 選用，輸入每個批次的最大記錄數。預設值為 100.

   2. 若為批次視窗 - 選用，請輸入在繼續之前收集記錄的秒數上限。