Connect 클러스터 나열

Connect 클러스터를 나열하면 클러스터 상태, 위치, 클러스터 가동시간, 컴퓨팅 크기, 연결된 Apache Kafka용 Google Cloud 관리형 서비스 클러스터, 라벨과 같은 세부정보를 포함하여 모든 Connect 클러스터의 세부정보를 한 창에서 볼 수 있습니다.

Connect 클러스터를 나열하려면 Google Cloud 콘솔, gcloud CLI, 클라이언트 라이브러리 또는 Managed Kafka API를 사용하면 됩니다. 오픈소스 Apache Kafka API를 사용하여 Connect 클러스터를 나열할 수 없습니다.

Connect 클러스터를 나열하는 데 필요한 역할 및 권한

Connect 클러스터를 나열하는 데 필요한 권한을 얻으려면 관리자에게 프로젝트에 대한 관리형 Kafka 뷰어 (roles/managedkafka.viewer) IAM 역할을 부여해 달라고 요청하세요. 역할 부여에 대한 자세한 내용은 프로젝트, 폴더, 조직에 대한 액세스 관리를 참조하세요.

이 사전 정의된 역할에는 Connect 클러스터를 나열하는 데 필요한 권한이 포함되어 있습니다. 필요한 정확한 권한을 보려면 필수 권한 섹션을 펼치세요.

필수 권한

Connect 클러스터를 나열하려면 다음 권한이 필요합니다.

지정된 위치에 목록 클러스터 권한을 부여합니다. managedkafka.connectClusters.list
지정된 위치에 클러스터 세부정보 가져오기 권한을 부여합니다. managedkafka.connectClusters.get

커스텀 역할이나 다른 사전 정의된 역할을 사용하여 이 권한을 부여받을 수도 있습니다.

관리형 Kafka 뷰어 역할에 대한 자세한 내용은 Apache Kafka용 관리형 서비스 사전 정의된 역할을 참고하세요.

Connect 클러스터 보기

콘솔

Google Cloud 콘솔에서 클러스터 연결 페이지로 이동합니다.

클러스터 연결로 이동
프로젝트에서 만든 클러스터가 나열됩니다. 이 페이지에서는 다음 클러스터 속성을 볼 수 있습니다.
- 이름: Connect 클러스터의 고유 식별자입니다. 이를 사용하여 다양한 작업에서 Connect 클러스터를 참조할 수 있습니다.
- 상태: Connect 클러스터의 현재 작동 상태를 나타냅니다(예: Active).
- 위치: Connect 클러스터가 호스팅되는 지리적 위치입니다.
- 업데이트 시간: Connect 클러스터가 마지막으로 업데이트된 시간입니다.
- vCPUs: Connect 클러스터에 할당된 vCPU 수입니다.
- 메모리: Connect 클러스터에 할당된 총 메모리 양입니다.
- 기본 Kafka 클러스터: Connect 클러스터와 연결된 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 설정 안내를 따르세요. 자세한 내용은 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 설정 안내를 따르세요. 자세한 내용은 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 설정 안내를 따르세요. 자세한 내용은 Apache Kafka용 관리형 서비스 Python API 참조 문서를 참고하세요.