列出 Connect 叢集

列出 Connect 叢集後，您就能在單一窗格中查看所有 Connect 叢集的詳細資料，包括叢集健康狀態、位置、叢集正常運作時間、運算大小、相關聯的 Google Cloud Managed Service for Apache Kafka 叢集和標籤等詳細資料。

如要列出 Connect 叢集，可以使用 Google Cloud 控制台、gcloud CLI、用戶端程式庫或 Managed Kafka API。您無法使用開放原始碼 Apache Kafka API 列出 Connect 叢集。

列出 Connect 叢集所需的角色和權限

如要取得列出 Connect 叢集所需的權限，請要求管理員授予您專案的「Managed Kafka 檢視者」 (roles/managedkafka.viewer) IAM 角色。如要進一步瞭解如何授予角色，請參閱「管理專案、資料夾和組織的存取權」。

這個預先定義的角色具備列出 Connect 叢集所需的權限。如要查看確切的必要權限，請展開「Required permissions」(必要權限) 部分：

所需權限

如要列出 Connect 叢集，必須具備下列權限：

在指定位置授予列出叢集的權限： managedkafka.connectClusters.list
在指定位置授予取得叢集詳細資料的權限： managedkafka.connectClusters.get

您或許還可透過自訂角色或其他預先定義的角色取得這些權限。

如要進一步瞭解 Managed Kafka Viewer 角色，請參閱「Managed Service for Apache Kafka 預先定義角色」。

查看 Connect 叢集

控制台

前往 Google Cloud 控制台的「Connect Clusters」(連結叢集) 頁面。

前往「Connect Clusters」(連結叢集)
系統會列出您在專案中建立的叢集。您可以在這個頁面查看下列叢集屬性：
- 名稱：Connect 叢集的專屬 ID。您可以在各種作業中參照 Connect 叢集。
- 狀態：指出 Connect 叢集的目前運作狀態，例如「有效」。
- 位置：Connect 叢集的代管地理位置。
- 更新時間：上次更新 Connect 叢集的時間。
- vCPUs：指派給 Connect 叢集的 vCPU 數量。
- 記憶體：分配給 Connect 叢集的記憶體總量。
- 主要 Kafka 叢集：與 Connect 叢集相關聯的 Managed Service for Apache Kafka 叢集。
- 標籤：可附加至 Connect 叢集的鍵/值組合，用於整理、篩選及自動化。

gcloud

In the Google Cloud console, activate Cloud Shell.

Activate Cloud Shell

At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.

使用 gcloud managed-kafka connect-clusters list 指令列出 Connect 叢集：

gcloud managed-kafka connect-clusters list \
    --location=LOCATION

如要進一步篩選 Connect 叢集清單，可以使用其他標記：
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION \
    [--filter=EXPRESSION] \
    [--limit=LIMIT] \
    [--page-size=PAGE_SIZE] \
    [--sort-by=SORT_BY]
```
更改下列內容：
- LOCATION：必填，要列出 Connect 叢集的位置。
- EXPRESSION：(選用) 要套用至清單的布林值篩選條件運算式。如果運算式評估結果為 True，系統就會在清單中加入項目。如需更多詳細資料和範例，請執行 gcloud topic filters。
- LIMIT：(選用) 要顯示的 Connect 叢集數量上限。如未指定，系統會列出所有 Connect 叢集。
- PAGE_SIZE：(選用) 每頁顯示的結果數。如未指定，服務會決定合適的網頁大小。
- SORT_BY：(選用) 以半形逗號分隔的欄位清單，做為排序依據。預設排序順序為遞增。如要遞減排序，請在欄位前面加上 ~。

輸出內容範例：

NAME                   VCPU  MEMORY_BYTES  STATE   NETWORK
connect-cluster-alpha  3     3221225472    ACTIVE
connect-cluster-beta   3     3221225472    ACTIVE

Go

在試用這個範例之前，請先按照「安裝用戶端程式庫」中的 Go 設定說明操作。詳情請參閱 Managed Service for Apache Kafka Go API 參考說明文件。

如要向 Managed Service for Apache Kafka 進行驗證，請設定應用程式預設憑證(ADC)。詳情請參閱「為本機開發環境設定 ADC」。

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/managedkafka/apiv1/managedkafkapb"
	"google.golang.org/api/iterator"
	"google.golang.org/api/option"

	managedkafka "cloud.google.com/go/managedkafka/apiv1"
)

func listConnectClusters(w io.Writer, projectID, region string, opts ...option.ClientOption) error {
	// projectID := "my-project-id"
	// region := "us-central1"
	ctx := context.Background()
	client, err := managedkafka.NewManagedKafkaConnectClient(ctx, opts...)
	if err != nil {
		return fmt.Errorf("managedkafka.NewManagedKafkaConnectClient got err: %w", err)
	}
	defer client.Close()

	locationPath := fmt.Sprintf("projects/%s/locations/%s", projectID, region)
	req := &managedkafkapb.ListConnectClustersRequest{
		Parent: locationPath,
	}
	clusterIter := client.ListConnectClusters(ctx, req)
	for {
		res, err := clusterIter.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			return fmt.Errorf("clusterIter.Next() got err: %w", err)
		}
		fmt.Fprintf(w, "Got connect cluster: %v", res)
	}
	return nil
}

Java

在試用這個範例之前，請先按照「安裝用戶端程式庫」中的 Java 設定操作說明進行操作。詳情請參閱 Managed Service for Apache Kafka Java API 參考說明文件。

如要向 Managed Service for Apache Kafka 進行驗證，請設定應用程式預設憑證。詳情請參閱「為本機開發環境設定 ADC」。

import com.google.api.gax.rpc.ApiException;
import com.google.cloud.managedkafka.v1.ConnectCluster;
import com.google.cloud.managedkafka.v1.LocationName;
import com.google.cloud.managedkafka.v1.ManagedKafkaConnectClient;
import java.io.IOException;

public class ListConnectClusters {

  public static void main(String[] args) throws Exception {
    // TODO(developer): Replace these variables before running the example.
    String projectId = "my-project-id";
    String region = "my-region"; // e.g. us-east1
    listConnectClusters(projectId, region);
  }

  public static void listConnectClusters(String projectId, String region) throws Exception {
    try (ManagedKafkaConnectClient managedKafkaConnectClient = 
        ManagedKafkaConnectClient.create()) {
      LocationName locationName = LocationName.of(projectId, region);
      // This operation is being handled synchronously.
      for (ConnectCluster connectCluster : managedKafkaConnectClient
          .listConnectClusters(locationName).iterateAll()) {
        System.out.println(connectCluster.getAllFields());
      }
    } catch (IOException | ApiException e) {
      System.err.printf("managedKafkaConnectClient.listConnectClusters got err: %s\n", 
          e.getMessage());
    }
  }
}

Python

在試用這個範例之前，請先按照「安裝用戶端程式庫」中的 Python 設定說明操作。詳情請參閱 Managed Service for Apache Kafka Python API 參考說明文件。

如要向 Managed Service for Apache Kafka 進行驗證，請設定應用程式預設憑證。詳情請參閱「為本機開發環境設定 ADC」。

from google.cloud import managedkafka_v1
from google.cloud.managedkafka_v1.services.managed_kafka_connect import (
    ManagedKafkaConnectClient,
)
from google.api_core.exceptions import GoogleAPICallError

# TODO(developer)
# project_id = "my-project-id"
# region = "us-central1"

connect_client = ManagedKafkaConnectClient()

request = managedkafka_v1.ListConnectClustersRequest(
    parent=connect_client.common_location_path(project_id, region),
)

response = connect_client.list_connect_clusters(request=request)
for cluster in response:
    try:
        print("Got Connect cluster:", cluster)
    except GoogleAPICallError as e:
        print(f"Failed to list Connect clusters with error: {e}")

後續步驟

Apache Kafka® 是 The Apache Software Foundation 或其關聯企業在美國與/或其他國家/地區的註冊商標。

列出 Connect 叢集 透過集合功能整理內容 你可以依據偏好儲存及分類內容。