Skip to content

Commit 887357d

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
feat: Add Managed Kafka Connect API (#13677)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 738170370 Source-Link: googleapis/googleapis@3f1e17a Source-Link: googleapis/googleapis-gen@9afd8c3 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLW1hbmFnZWRrYWZrYS8uT3dsQm90LnlhbWwiLCJoIjoiOWFmZDhjMzNkNGNhZTYxMGI3NWZhNDk5OTI2NGVhOGM4YzY2YjlkMiJ9 BEGIN_NESTED_COMMIT feat: [google-cloud-managedkafka] add Managed Kafka Connect API PiperOrigin-RevId: 738085357 Source-Link: googleapis/googleapis@9eee08a Source-Link: googleapis/googleapis-gen@f75a1dd Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLW1hbmFnZWRrYWZrYS8uT3dsQm90LnlhbWwiLCJoIjoiZjc1YTFkZGVlNjM0ODYxZmMyYmQxZmYyMmQ2ODE1OWU3Njk5YjJjMCJ9 END_NESTED_COMMIT --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent c4a31dc commit 887357d

File tree

99 files changed

+33111
-88
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

99 files changed

+33111
-88
lines changed

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

+10
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
ManagedKafkaConnect
2+
-------------------------------------
3+
4+
.. automodule:: google.cloud.managedkafka_v1.services.managed_kafka_connect
5+
:members:
6+
:inherited-members:
7+
8+
.. automodule:: google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers
9+
:members:
10+
:inherited-members:

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

+1
Original file line numberDiff line numberDiff line change
@@ -4,3 +4,4 @@ Services for Google Cloud Managedkafka v1 API
44
:maxdepth: 2
55

66
managed_kafka
7+
managed_kafka_connect

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

+63-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
# -*- coding: utf-8 -*-
2-
# Copyright 2024 Google LLC
2+
# Copyright 2025 Google LLC
33
#
44
# Licensed under the Apache License, Version 2.0 (the "License");
55
# you may not use this file except in compliance with the License.
@@ -24,6 +24,12 @@
2424
from google.cloud.managedkafka_v1.services.managed_kafka.client import (
2525
ManagedKafkaClient,
2626
)
27+
from google.cloud.managedkafka_v1.services.managed_kafka_connect.async_client import (
28+
ManagedKafkaConnectAsyncClient,
29+
)
30+
from google.cloud.managedkafka_v1.services.managed_kafka_connect.client import (
31+
ManagedKafkaConnectClient,
32+
)
2733
from google.cloud.managedkafka_v1.types.managed_kafka import (
2834
CreateClusterRequest,
2935
CreateTopicRequest,
@@ -43,23 +49,53 @@
4349
UpdateConsumerGroupRequest,
4450
UpdateTopicRequest,
4551
)
52+
from google.cloud.managedkafka_v1.types.managed_kafka_connect import (
53+
CreateConnectClusterRequest,
54+
CreateConnectorRequest,
55+
DeleteConnectClusterRequest,
56+
DeleteConnectorRequest,
57+
GetConnectClusterRequest,
58+
GetConnectorRequest,
59+
ListConnectClustersRequest,
60+
ListConnectClustersResponse,
61+
ListConnectorsRequest,
62+
ListConnectorsResponse,
63+
PauseConnectorRequest,
64+
PauseConnectorResponse,
65+
RestartConnectorRequest,
66+
RestartConnectorResponse,
67+
ResumeConnectorRequest,
68+
ResumeConnectorResponse,
69+
StopConnectorRequest,
70+
StopConnectorResponse,
71+
UpdateConnectClusterRequest,
72+
UpdateConnectorRequest,
73+
)
4674
from google.cloud.managedkafka_v1.types.resources import (
4775
AccessConfig,
4876
CapacityConfig,
4977
Cluster,
78+
ConnectAccessConfig,
79+
ConnectCluster,
80+
ConnectGcpConfig,
81+
ConnectNetworkConfig,
82+
Connector,
5083
ConsumerGroup,
5184
ConsumerPartitionMetadata,
5285
ConsumerTopicMetadata,
5386
GcpConfig,
5487
NetworkConfig,
5588
OperationMetadata,
5689
RebalanceConfig,
90+
TaskRetryPolicy,
5791
Topic,
5892
)
5993

6094
__all__ = (
6195
"ManagedKafkaClient",
6296
"ManagedKafkaAsyncClient",
97+
"ManagedKafkaConnectClient",
98+
"ManagedKafkaConnectAsyncClient",
6399
"CreateClusterRequest",
64100
"CreateTopicRequest",
65101
"DeleteClusterRequest",
@@ -77,15 +113,41 @@
77113
"UpdateClusterRequest",
78114
"UpdateConsumerGroupRequest",
79115
"UpdateTopicRequest",
116+
"CreateConnectClusterRequest",
117+
"CreateConnectorRequest",
118+
"DeleteConnectClusterRequest",
119+
"DeleteConnectorRequest",
120+
"GetConnectClusterRequest",
121+
"GetConnectorRequest",
122+
"ListConnectClustersRequest",
123+
"ListConnectClustersResponse",
124+
"ListConnectorsRequest",
125+
"ListConnectorsResponse",
126+
"PauseConnectorRequest",
127+
"PauseConnectorResponse",
128+
"RestartConnectorRequest",
129+
"RestartConnectorResponse",
130+
"ResumeConnectorRequest",
131+
"ResumeConnectorResponse",
132+
"StopConnectorRequest",
133+
"StopConnectorResponse",
134+
"UpdateConnectClusterRequest",
135+
"UpdateConnectorRequest",
80136
"AccessConfig",
81137
"CapacityConfig",
82138
"Cluster",
139+
"ConnectAccessConfig",
140+
"ConnectCluster",
141+
"ConnectGcpConfig",
142+
"ConnectNetworkConfig",
143+
"Connector",
83144
"ConsumerGroup",
84145
"ConsumerPartitionMetadata",
85146
"ConsumerTopicMetadata",
86147
"GcpConfig",
87148
"NetworkConfig",
88149
"OperationMetadata",
89150
"RebalanceConfig",
151+
"TaskRetryPolicy",
90152
"Topic",
91153
)

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

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

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

+61-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
# -*- coding: utf-8 -*-
2-
# Copyright 2024 Google LLC
2+
# Copyright 2025 Google LLC
33
#
44
# Licensed under the Apache License, Version 2.0 (the "License");
55
# you may not use this file except in compliance with the License.
@@ -19,6 +19,10 @@
1919

2020

2121
from .services.managed_kafka import ManagedKafkaAsyncClient, ManagedKafkaClient
22+
from .services.managed_kafka_connect import (
23+
ManagedKafkaConnectAsyncClient,
24+
ManagedKafkaConnectClient,
25+
)
2226
from .types.managed_kafka import (
2327
CreateClusterRequest,
2428
CreateTopicRequest,
@@ -38,49 +42,105 @@
3842
UpdateConsumerGroupRequest,
3943
UpdateTopicRequest,
4044
)
45+
from .types.managed_kafka_connect import (
46+
CreateConnectClusterRequest,
47+
CreateConnectorRequest,
48+
DeleteConnectClusterRequest,
49+
DeleteConnectorRequest,
50+
GetConnectClusterRequest,
51+
GetConnectorRequest,
52+
ListConnectClustersRequest,
53+
ListConnectClustersResponse,
54+
ListConnectorsRequest,
55+
ListConnectorsResponse,
56+
PauseConnectorRequest,
57+
PauseConnectorResponse,
58+
RestartConnectorRequest,
59+
RestartConnectorResponse,
60+
ResumeConnectorRequest,
61+
ResumeConnectorResponse,
62+
StopConnectorRequest,
63+
StopConnectorResponse,
64+
UpdateConnectClusterRequest,
65+
UpdateConnectorRequest,
66+
)
4167
from .types.resources import (
4268
AccessConfig,
4369
CapacityConfig,
4470
Cluster,
71+
ConnectAccessConfig,
72+
ConnectCluster,
73+
ConnectGcpConfig,
74+
ConnectNetworkConfig,
75+
Connector,
4576
ConsumerGroup,
4677
ConsumerPartitionMetadata,
4778
ConsumerTopicMetadata,
4879
GcpConfig,
4980
NetworkConfig,
5081
OperationMetadata,
5182
RebalanceConfig,
83+
TaskRetryPolicy,
5284
Topic,
5385
)
5486

5587
__all__ = (
5688
"ManagedKafkaAsyncClient",
89+
"ManagedKafkaConnectAsyncClient",
5790
"AccessConfig",
5891
"CapacityConfig",
5992
"Cluster",
93+
"ConnectAccessConfig",
94+
"ConnectCluster",
95+
"ConnectGcpConfig",
96+
"ConnectNetworkConfig",
97+
"Connector",
6098
"ConsumerGroup",
6199
"ConsumerPartitionMetadata",
62100
"ConsumerTopicMetadata",
63101
"CreateClusterRequest",
102+
"CreateConnectClusterRequest",
103+
"CreateConnectorRequest",
64104
"CreateTopicRequest",
65105
"DeleteClusterRequest",
106+
"DeleteConnectClusterRequest",
107+
"DeleteConnectorRequest",
66108
"DeleteConsumerGroupRequest",
67109
"DeleteTopicRequest",
68110
"GcpConfig",
69111
"GetClusterRequest",
112+
"GetConnectClusterRequest",
113+
"GetConnectorRequest",
70114
"GetConsumerGroupRequest",
71115
"GetTopicRequest",
72116
"ListClustersRequest",
73117
"ListClustersResponse",
118+
"ListConnectClustersRequest",
119+
"ListConnectClustersResponse",
120+
"ListConnectorsRequest",
121+
"ListConnectorsResponse",
74122
"ListConsumerGroupsRequest",
75123
"ListConsumerGroupsResponse",
76124
"ListTopicsRequest",
77125
"ListTopicsResponse",
78126
"ManagedKafkaClient",
127+
"ManagedKafkaConnectClient",
79128
"NetworkConfig",
80129
"OperationMetadata",
130+
"PauseConnectorRequest",
131+
"PauseConnectorResponse",
81132
"RebalanceConfig",
133+
"RestartConnectorRequest",
134+
"RestartConnectorResponse",
135+
"ResumeConnectorRequest",
136+
"ResumeConnectorResponse",
137+
"StopConnectorRequest",
138+
"StopConnectorResponse",
139+
"TaskRetryPolicy",
82140
"Topic",
83141
"UpdateClusterRequest",
142+
"UpdateConnectClusterRequest",
143+
"UpdateConnectorRequest",
84144
"UpdateConsumerGroupRequest",
85145
"UpdateTopicRequest",
86146
)

0 commit comments

Comments
 (0)