feat: Add Managed Kafka Connect API

packages/google-cloud-managedkafka/docs/managedkafka_v1/managed_kafka_connect.rst

@@ -0,0 +1,10 @@
+ManagedKafkaConnect
+-------------------------------------
+
+.. automodule:: google.cloud.managedkafka_v1.services.managed_kafka_connect
+    :members:
+    :inherited-members:
+
+.. automodule:: google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers
+    :members:
+    :inherited-members:

packages/google-cloud-managedkafka/docs/managedkafka_v1/services_.rst

@@ -4,3 +4,4 @@ Services for Google Cloud Managedkafka v1 API
     :maxdepth: 2
 
     managed_kafka
+    managed_kafka_connect

packages/google-cloud-managedkafka/google/cloud/managedkafka/__init__.py

@@ -1,5 +1,5 @@
 # -*- coding: utf-8 -*-
-# Copyright 2024 Google LLC
+# Copyright 2025 Google LLC
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -24,6 +24,12 @@
 from google.cloud.managedkafka_v1.services.managed_kafka.client import (
     ManagedKafkaClient,
 )
+from google.cloud.managedkafka_v1.services.managed_kafka_connect.async_client import (
+    ManagedKafkaConnectAsyncClient,
+)
+from google.cloud.managedkafka_v1.services.managed_kafka_connect.client import (
+    ManagedKafkaConnectClient,
+)
 from google.cloud.managedkafka_v1.types.managed_kafka import (
     CreateClusterRequest,
     CreateTopicRequest,
@@ -43,23 +49,53 @@
     UpdateConsumerGroupRequest,
     UpdateTopicRequest,
 )
+from google.cloud.managedkafka_v1.types.managed_kafka_connect import (
+    CreateConnectClusterRequest,
+    CreateConnectorRequest,
+    DeleteConnectClusterRequest,
+    DeleteConnectorRequest,
+    GetConnectClusterRequest,
+    GetConnectorRequest,
+    ListConnectClustersRequest,
+    ListConnectClustersResponse,
+    ListConnectorsRequest,
+    ListConnectorsResponse,
+    PauseConnectorRequest,
+    PauseConnectorResponse,
+    RestartConnectorRequest,
+    RestartConnectorResponse,
+    ResumeConnectorRequest,
+    ResumeConnectorResponse,
+    StopConnectorRequest,
+    StopConnectorResponse,
+    UpdateConnectClusterRequest,
+    UpdateConnectorRequest,
+)
 from google.cloud.managedkafka_v1.types.resources import (
     AccessConfig,
     CapacityConfig,
     Cluster,
+    ConnectAccessConfig,
+    ConnectCluster,
+    ConnectGcpConfig,
+    ConnectNetworkConfig,
+    Connector,
     ConsumerGroup,
     ConsumerPartitionMetadata,
     ConsumerTopicMetadata,
     GcpConfig,
     NetworkConfig,
     OperationMetadata,
     RebalanceConfig,
+    TaskRetryPolicy,
     Topic,
 )
 
 __all__ = (
     "ManagedKafkaClient",
     "ManagedKafkaAsyncClient",
+    "ManagedKafkaConnectClient",
+    "ManagedKafkaConnectAsyncClient",
     "CreateClusterRequest",
     "CreateTopicRequest",
     "DeleteClusterRequest",
@@ -77,15 +113,41 @@
     "UpdateClusterRequest",
     "UpdateConsumerGroupRequest",
     "UpdateTopicRequest",
+    "CreateConnectClusterRequest",
+    "CreateConnectorRequest",
+    "DeleteConnectClusterRequest",
+    "DeleteConnectorRequest",
+    "GetConnectClusterRequest",
+    "GetConnectorRequest",
+    "ListConnectClustersRequest",
+    "ListConnectClustersResponse",
+    "ListConnectorsRequest",
+    "ListConnectorsResponse",
+    "PauseConnectorRequest",
+    "PauseConnectorResponse",
+    "RestartConnectorRequest",
+    "RestartConnectorResponse",
+    "ResumeConnectorRequest",
+    "ResumeConnectorResponse",
+    "StopConnectorRequest",
+    "StopConnectorResponse",
+    "UpdateConnectClusterRequest",
+    "UpdateConnectorRequest",
     "AccessConfig",
     "CapacityConfig",
     "Cluster",
+    "ConnectAccessConfig",
+    "ConnectCluster",
+    "ConnectGcpConfig",
+    "ConnectNetworkConfig",
+    "Connector",
     "ConsumerGroup",
     "ConsumerPartitionMetadata",
     "ConsumerTopicMetadata",
     "GcpConfig",
     "NetworkConfig",
     "OperationMetadata",
     "RebalanceConfig",
+    "TaskRetryPolicy",
     "Topic",
 )

packages/google-cloud-managedkafka/google/cloud/managedkafka/gapic_version.py

@@ -1,5 +1,5 @@
 # -*- coding: utf-8 -*-
-# Copyright 2024 Google LLC
+# Copyright 2025 Google LLC
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "0.1.8"  # {x-release-please-version}
+__version__ = "0.0.0"  # {x-release-please-version}

packages/google-cloud-managedkafka/google/cloud/managedkafka_v1/__init__.py

@@ -1,5 +1,5 @@
 # -*- coding: utf-8 -*-
-# Copyright 2024 Google LLC
+# Copyright 2025 Google LLC
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -19,6 +19,10 @@
 
 
 from .services.managed_kafka import ManagedKafkaAsyncClient, ManagedKafkaClient
+from .services.managed_kafka_connect import (
+    ManagedKafkaConnectAsyncClient,
+    ManagedKafkaConnectClient,
+)
 from .types.managed_kafka import (
     CreateClusterRequest,
     CreateTopicRequest,
@@ -38,49 +42,105 @@
     UpdateConsumerGroupRequest,
     UpdateTopicRequest,
 )
+from .types.managed_kafka_connect import (
+    CreateConnectClusterRequest,
+    CreateConnectorRequest,
+    DeleteConnectClusterRequest,
+    DeleteConnectorRequest,
+    GetConnectClusterRequest,
+    GetConnectorRequest,
+    ListConnectClustersRequest,
+    ListConnectClustersResponse,
+    ListConnectorsRequest,
+    ListConnectorsResponse,
+    PauseConnectorRequest,
+    PauseConnectorResponse,
+    RestartConnectorRequest,
+    RestartConnectorResponse,
+    ResumeConnectorRequest,
+    ResumeConnectorResponse,
+    StopConnectorRequest,
+    StopConnectorResponse,
+    UpdateConnectClusterRequest,
+    UpdateConnectorRequest,
+)
 from .types.resources import (
     AccessConfig,
     CapacityConfig,
     Cluster,
+    ConnectAccessConfig,
+    ConnectCluster,
+    ConnectGcpConfig,
+    ConnectNetworkConfig,
+    Connector,
     ConsumerGroup,
     ConsumerPartitionMetadata,
     ConsumerTopicMetadata,
     GcpConfig,
     NetworkConfig,
     OperationMetadata,
     RebalanceConfig,
+    TaskRetryPolicy,
     Topic,
 )
 
 __all__ = (
     "ManagedKafkaAsyncClient",
+    "ManagedKafkaConnectAsyncClient",
     "AccessConfig",
     "CapacityConfig",
     "Cluster",
+    "ConnectAccessConfig",
+    "ConnectCluster",
+    "ConnectGcpConfig",
+    "ConnectNetworkConfig",
+    "Connector",
     "ConsumerGroup",
     "ConsumerPartitionMetadata",
     "ConsumerTopicMetadata",
     "CreateClusterRequest",
+    "CreateConnectClusterRequest",
+    "CreateConnectorRequest",
     "CreateTopicRequest",
     "DeleteClusterRequest",
+    "DeleteConnectClusterRequest",
+    "DeleteConnectorRequest",
     "DeleteConsumerGroupRequest",
     "DeleteTopicRequest",
     "GcpConfig",
     "GetClusterRequest",
+    "GetConnectClusterRequest",
+    "GetConnectorRequest",
     "GetConsumerGroupRequest",
     "GetTopicRequest",
     "ListClustersRequest",
     "ListClustersResponse",
+    "ListConnectClustersRequest",
+    "ListConnectClustersResponse",
+    "ListConnectorsRequest",
+    "ListConnectorsResponse",
     "ListConsumerGroupsRequest",
     "ListConsumerGroupsResponse",
     "ListTopicsRequest",
     "ListTopicsResponse",
     "ManagedKafkaClient",
+    "ManagedKafkaConnectClient",
     "NetworkConfig",
     "OperationMetadata",
+    "PauseConnectorRequest",
+    "PauseConnectorResponse",
     "RebalanceConfig",
+    "RestartConnectorRequest",
+    "RestartConnectorResponse",
+    "ResumeConnectorRequest",
+    "ResumeConnectorResponse",
+    "StopConnectorRequest",
+    "StopConnectorResponse",
+    "TaskRetryPolicy",
     "Topic",
     "UpdateClusterRequest",
+    "UpdateConnectClusterRequest",
+    "UpdateConnectorRequest",
     "UpdateConsumerGroupRequest",
     "UpdateTopicRequest",
 )