Package com.google.cloud.managedkafka.v1


@Generated("by gapic-generator-java") package com.google.cloud.managedkafka.v1
A client to Managed Service for Apache Kafka API

The interfaces provided are listed below, along with usage samples.

======================= ManagedKafkaClient =======================

Service Description: The service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.

Sample for ManagedKafkaClient:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (ManagedKafkaClient managedKafkaClient = ManagedKafkaClient.create()) {
   ClusterName name = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   Cluster response = managedKafkaClient.getCluster(name);
 }
 

======================= ManagedKafkaConnectClient =======================

Service Description: The service that a client application uses to manage Apache Kafka Connect clusters and connectors.

Sample for ManagedKafkaConnectClient:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (ManagedKafkaConnectClient managedKafkaConnectClient = ManagedKafkaConnectClient.create()) {
   ConnectClusterName name =
       ConnectClusterName.of("[PROJECT]", "[LOCATION]", "[CONNECT_CLUSTER]");
   ConnectCluster response = managedKafkaConnectClient.getConnectCluster(name);
 }