View a connector
Stay organized with collections Save and categorize content based on your preferences.

Viewing a connector's details lets you inspect its configuration, operational state, task restart policy, and monitor its performance metrics.

To view the details of a connector in a Connect cluster, you can use the Google Cloud console, the gcloud CLI, the Managed Service for Apache Kafka client library, or the Managed Kafka API. You can't use the open source Apache Kafka API to view the connectors.

Required roles and permissions to view a connector

To get the permissions that you need to view a connector, ask your administrator to grant you the Managed Kafka Viewer (roles/managedkafka.viewer) IAM role on your project. For more information about granting roles, see Manage access to projects, folders, and organizations.

This predefined role contains the permissions required to view a connector. To see the exact permissions that are required, expand the Required permissions section:

Required permissions

The following permissions are required to view a connector:

Grant the list connectors permission on the parent Connect cluster: managedkafka.connectors.list
Grant the get connector details permission on the parent Connect cluster: managedkafka.connectors.get

You might also be able to get these permissions with custom roles or other predefined roles.

For more information about the Managed Kafka Viewer role, see Managed Service for Apache Kafka predefined roles.

View connector details

Console

In the Google Cloud console, go to the Connect clusters page.

Go to Connect clusters
Click the Connect cluster that hosts the connector you want to view.

The Connect cluster details page is displayed.
On the Resources tab, find the connector in the list and click its name. You are redirected to the Connector details page.
The Connector details page displays the following tabs:
- Configuration: Shows the connector's configuration, including:
  - Name: The name of the connector.
  - State: The operational state of the connector. For example, Running.
  - Task restart policy: The policy for restarting failed tasks. For example, whether to restart failed tasks or not, and with which backoff settings.
  - Configuration properties: A list of key-value pairs defining the connector's configuration.
- Monitoring: Provides graphs for monitoring the connector, such as:
  - Task error count: The number of tasks that have encountered errors.
  - Active task count: The number of tasks that are currently active.

This page also includes buttons to edit, delete, pause, stop, and restart the connector.

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.
Use the gcloud alpha managed-kafka connectors describe command to describe a connector:
```
gcloud alpha managed-kafka connectors describe CONNECTOR_ID \
    --location=LOCATION \
    --connect_cluster=CONNECT_CLUSTER_ID
```
Replace the following:
- CONNECTOR_ID: Required. The ID of the connector you want to describe.
- LOCATION: Required. The location of the Connect cluster containing the connector.
- CONNECT_CLUSTER_ID: Required. The ID of the Connect cluster containing the connector.

Example command:

gcloud alpha managed-kafka connectors describe test-connector \
    --location=us-central1 \
    --connect_cluster=test-connect-cluster

Example output:

config:
  connector.class: com.google.cloud.kafka.connect.pubsub.PubsubSinkConnector
  kafka.topic.regex: .*
  key.converter: org.apache.kafka.connect.storage.StringConverter
  project: test-project
  tasks.max: '1'
  topic: test-pubsub-topic
  value.converter: org.apache.kafka.connect.json.JsonConverter
  value.converter.schemas.enable: 'false'
createTime: '2024-03-13T05:17:34.123456Z'
labels:
  test-label-key: test-label-value
name: projects/test-project/locations/us-central1/connectClusters/test-connect-cluster/connectors/test-connector
state: RUNNING
taskRestartPolicy: RESTART_WITH_EXPONENTIAL_BACKOFF
updateTime: '2024-03-13T05:18:15.987654Z'

Apache Kafka® is a registered trademark of The Apache Software Foundation or its affiliates in the United States and/or other countries.