DataHub：Topic操作

建立Topic

使用者點擊Project詳情頁面中的建立Topic按鈕，進行Topic的建立。可以通過兩種方式建立Topic

自訂格式建立

注意：開啟Shard擴充模式，shard支援水平擴充，不再支援“合并”和“分裂”，以後shard數量只能增加，不可減少。此模式開啟後可以使用kafka方式來消費當前Topic

使用者可根據業務需求進行Topic的建立，各選項的意義可查看協助文檔中的基本概念。

通過匯入MaxCompute表結構進行建立

步驟一

需要指定訪問MaxCompute的相關參數：

步驟二

點擊下一步,匯入MaxCompute的表結構，表結構中的Topic名稱、欄位注釋以及欄位是否為空白可以根據需要進行修改注意：開啟Shard擴充模式，shard支援水平擴充，不再支援“合并”和“分裂”，以後shard數量只能增加，不可減少。此模式開啟後可以使用kafka方式來消費當前Topic

查看Topic

1.進入Project頁面，點擊查看按鈕

2.查看Topic各項詳情，如Topic儲存量

刪除Topic

使用者點擊Topic列表中的刪除按鈕可進行Topic的刪除。需要注意的是，一旦刪除Topic，該Topic下的資料，資源（Shard, Connector）均被刪除，無法恢複，請謹慎操作。

修改Topic生命週期

DataHub 可以修改Topic的生命週期參考代碼如下：

• 參數

  • projectName The name of the project in which you get.

  • topicName The name of the topic.

  • lifeCycle The lifeCycle of the topic.

  • comment The comment of the topic.

• Exception

  • DatahubClientException

  • InvalidParameterException

  • AuthorizationFailureException

  • ResourceNotFoundException

• 樣本

  public static void updatetopic() {
    try {
        int lifeCycle = 7;
        String comment = "test";
        datahubClient.updateTopic(Constant.projectName, Constant.topicName,liefCycle,comment );
        System.out.println("update topicLifeCycle success!");
    } catch (InvalidParameterException e) {
        System.out.println("invalid parameter, please check your parameter");
        System.exit(1);
    } catch (AuthorizationFailureException e) {
        System.out.println("AK error, please check your accessId and accessKey");
        System.exit(1);
    } catch (ResourceNotFoundException e) {
        System.out.println("project or topic not found");
        System.exit(1);
    } catch (DatahubClientException e) {
        System.out.println("other error");
        System.exit(1);
    }
  }