Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions api_names_out.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -325184,6 +325184,7 @@
"/managedkafka:v1/AccessConfig": access_config
"/managedkafka:v1/AccessConfig/networkConfigs": network_configs
"/managedkafka:v1/AccessConfig/networkConfigs/network_config": network_config
"/managedkafka:v1/AccessConfig/publicClusterConfig": public_cluster_config
"/managedkafka:v1/Acl": acl
"/managedkafka:v1/Acl/aclEntries": acl_entries
"/managedkafka:v1/Acl/aclEntries/acl_entry": acl_entry
Expand All @@ -325200,6 +325201,8 @@
"/managedkafka:v1/AddAclEntryResponse": add_acl_entry_response
"/managedkafka:v1/AddAclEntryResponse/acl": acl
"/managedkafka:v1/AddAclEntryResponse/aclCreated": acl_created
"/managedkafka:v1/BrokerCapacityConfig": broker_capacity_config
"/managedkafka:v1/BrokerCapacityConfig/diskSizeGib": disk_size_gib
"/managedkafka:v1/BrokerDetails": broker_details
"/managedkafka:v1/BrokerDetails/brokerIndex": broker_index
"/managedkafka:v1/BrokerDetails/nodeId": node_id
Expand All @@ -325221,15 +325224,19 @@
"/managedkafka:v1/CheckCompatibilityResponse/messages": messages
"/managedkafka:v1/CheckCompatibilityResponse/messages/message": message
"/managedkafka:v1/Cluster": cluster
"/managedkafka:v1/Cluster/bootstrapAddress": bootstrap_address
"/managedkafka:v1/Cluster/brokerCapacityConfig": broker_capacity_config
"/managedkafka:v1/Cluster/brokerDetails": broker_details
"/managedkafka:v1/Cluster/brokerDetails/broker_detail": broker_detail
"/managedkafka:v1/Cluster/capacityConfig": capacity_config
"/managedkafka:v1/Cluster/createTime": create_time
"/managedkafka:v1/Cluster/effectiveCapacityConfig": effective_capacity_config
"/managedkafka:v1/Cluster/gcpConfig": gcp_config
"/managedkafka:v1/Cluster/kafkaVersion": kafka_version
"/managedkafka:v1/Cluster/labels": labels
"/managedkafka:v1/Cluster/labels/label": label
"/managedkafka:v1/Cluster/name": name
"/managedkafka:v1/Cluster/publicClusterDetails": public_cluster_details
"/managedkafka:v1/Cluster/rebalanceConfig": rebalance_config
"/managedkafka:v1/Cluster/satisfiesPzi": satisfies_pzi
"/managedkafka:v1/Cluster/satisfiesPzs": satisfies_pzs
Expand Down Expand Up @@ -325297,6 +325304,9 @@
"/managedkafka:v1/CreateVersionRequest/version": version
"/managedkafka:v1/CreateVersionResponse": create_version_response
"/managedkafka:v1/CreateVersionResponse/id": id
"/managedkafka:v1/EffectiveCapacityConfig": effective_capacity_config
"/managedkafka:v1/EffectiveCapacityConfig/brokerCount": broker_count
"/managedkafka:v1/EffectiveCapacityConfig/brokerDiskSizeGib": broker_disk_size_gib
"/managedkafka:v1/Empty": empty
"/managedkafka:v1/GcpConfig": gcp_config
"/managedkafka:v1/GcpConfig/accessConfig": access_config
Expand Down Expand Up @@ -325383,6 +325393,14 @@
"/managedkafka:v1/OperationMetadata/verb": verb
"/managedkafka:v1/PauseConnectorRequest": pause_connector_request
"/managedkafka:v1/PauseConnectorResponse": pause_connector_response
"/managedkafka:v1/PublicClusterConfig": public_cluster_config
"/managedkafka:v1/PublicClusterConfig/allowedSourceIpRanges": allowed_source_ip_ranges
"/managedkafka:v1/PublicClusterConfig/allowedSourceIpRanges/allowed_source_ip_range": allowed_source_ip_range
"/managedkafka:v1/PublicClusterDetails": public_cluster_details
"/managedkafka:v1/PublicClusterDetails/discoveryDnsRecords": discovery_dns_records
"/managedkafka:v1/PublicClusterDetails/discoveryDnsRecords/discovery_dns_record": discovery_dns_record
"/managedkafka:v1/PublicClusterDetails/externalIpAddresses": external_ip_addresses
"/managedkafka:v1/PublicClusterDetails/externalIpAddresses/external_ip_address": external_ip_address
"/managedkafka:v1/RebalanceConfig": rebalance_config
"/managedkafka:v1/RebalanceConfig/mode": mode
"/managedkafka:v1/RemoveAclEntryResponse": remove_acl_entry_response
Expand Down
4 changes: 4 additions & 0 deletions generated/google-apis-managedkafka_v1/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,9 @@
# Release history for google-apis-managedkafka_v1

### v0.26.0 (2026-09-06)

* Regenerated from discovery document revision 20260827

### v0.25.0 (2026-06-14)

* Regenerated using generator version 0.19.0
Expand Down
74 changes: 37 additions & 37 deletions generated/google-apis-managedkafka_v1/Gemfile.lock
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
PATH
remote: .
specs:
google-apis-managedkafka_v1 (0.25.0)
google-apis-managedkafka_v1 (0.26.0)
google-apis-core (>= 0.15.0, < 2.a)

GEM
Expand Down Expand Up @@ -97,43 +97,43 @@ DEPENDENCIES
yard (~> 0.9, >= 0.9.25)

CHECKSUMS
addressable (2.9.0)
base64 (0.3.0)
addressable (2.9.0) sha256=7fdf6ac3660f7f4e867a0838be3f6cf722ace541dd97767fa42bc6cfa980c7af
base64 (0.3.0) sha256=27337aeabad6ffae05c265c450490628ef3ebd4b67be58257393227588f5a97b
bundler (4.0.14) sha256=d09a0a965cf772266a7e49e83610be7c2f4e49e61134c42a56804bb383cc24b8
declarative (0.0.20)
diff-lcs (1.6.2)
faraday (2.14.3)
faraday-follow_redirects (0.5.0)
faraday-net_http (3.4.4)
google-apis-core (1.2.1)
google-apis-managedkafka_v1 (0.25.0)
google-cloud-env (2.3.1)
google-logging-utils (0.2.0)
googleauth (1.17.1)
json (2.20.0)
jwt (3.2.0)
logger (1.7.0)
mini_mime (1.1.5)
multi_json (1.21.1)
net-http (0.9.1)
opencensus (0.5.0)
os (1.1.4)
pstore (0.2.1)
public_suffix (7.0.5)
rake (13.4.2)
redcarpet (3.6.1)
representable (3.2.0)
retriable (3.8.0)
rspec (3.13.2)
rspec-core (3.13.6)
rspec-expectations (3.13.5)
rspec-mocks (3.13.8)
rspec-support (3.13.7)
signet (0.22.0)
trailblazer-option (0.1.2)
uber (0.1.0)
uri (1.1.1)
yard (0.9.44)
declarative (0.0.20) sha256=8021dd6cb17ab2b61233c56903d3f5a259c5cf43c80ff332d447d395b17d9ff9
diff-lcs (1.6.2) sha256=9ae0d2cba7d4df3075fe8cd8602a8604993efc0dfa934cff568969efb1909962
faraday (2.14.3) sha256=1882247e6766615c8220b4392bf1d27f6ebb63d8e28267587cef1fb0bf37f278
faraday-follow_redirects (0.5.0) sha256=5cde93c894b30943a5d2b93c2fe9284216a6b756f7af406a1e55f211d97d10ad
faraday-net_http (3.4.4) sha256=0e78af151747ed1b00f33e25973b4bc220d7f16c00c39676817c8b12331eb588
google-apis-core (1.2.1) sha256=3739030455277e3be90f2d07321ad4d0bf0d6b1ed820b2d092916d6cdef05337
google-apis-managedkafka_v1 (0.26.0)
google-cloud-env (2.3.1) sha256=0faac01eb27be78c2591d64433663b1a114f8f7af55a4f819755426cac9178e7
google-logging-utils (0.2.0) sha256=675462b4ea5affa825a3442694ca2d75d0069455a1d0956127207498fca3df7b
googleauth (1.17.1) sha256=0f7e6fc70e204cee1b2d71f1e1de2d3b349d432404197fe68ebf7fa23d0821b9
json (2.20.0) sha256=9362bc6e55a952b056abf9167cf053358181c904cb70cd6eee0808ea830fc32b
jwt (3.2.0) sha256=5419b1fe37b1da0982bd07051f573a8b8789ab724c2aa7e785e4784a3ed217d7
logger (1.7.0) sha256=196edec7cc44b66cfb40f9755ce11b392f21f7967696af15d274dde7edff0203
mini_mime (1.1.5) sha256=8681b7e2e4215f2a159f9400b5816d85e9d8c6c6b491e96a12797e798f8bccef
multi_json (1.21.1) sha256=e6126a31808e3b4d19f483c775ceac34df190dffa62adfb63a165ee14ba68080
net-http (0.9.1) sha256=25ba0b67c63e89df626ed8fac771d0ad24ad151a858af2cc8e6a716ca4336996
opencensus (0.5.0) sha256=0456d1878fd91685c21a4bfa7feac85480a0c3bc969d25550f6d3f36dd75cbba
os (1.1.4) sha256=57816d6a334e7bd6aed048f4b0308226c5fb027433b67d90a9ab435f35108d3f
pstore (0.2.1) sha256=03904d0f2c66579e96d1e6704cdabc0c88df7ea8ed8782d9f3569f6f6c702c1a
public_suffix (7.0.5) sha256=1a8bb08f1bbea19228d3bed6e5ed908d1cb4f7c2726d18bd9cadf60bc676f623
rake (13.4.2) sha256=cb825b2bd5f1f8e91ca37bddb4b9aaf345551b4731da62949be002fa89283701
redcarpet (3.6.1) sha256=d444910e6aa55480c6bcdc0cdb057626e8a32c054c29e793fa642ba2f155f445
representable (3.2.0) sha256=cc29bf7eebc31653586849371a43ffe36c60b54b0a6365b5f7d95ec34d1ebace
retriable (3.8.0) sha256=9f2f1b0207594c7817f17f671587b8ec7587387ac6cebda6c941a802bb98a8e5
rspec (3.13.2) sha256=206284a08ad798e61f86d7ca3e376718d52c0bc944626b2349266f239f820587
rspec-core (3.13.6) sha256=a8823c6411667b60a8bca135364351dda34cd55e44ff94c4be4633b37d828b2d
rspec-expectations (3.13.5) sha256=33a4d3a1d95060aea4c94e9f237030a8f9eae5615e9bd85718fe3a09e4b58836
rspec-mocks (3.13.8) sha256=086ad3d3d17533f4237643de0b5c42f04b66348c28bf6b9c2d3f4a3b01af1d47
rspec-support (3.13.7) sha256=0640e5570872aafefd79867901deeeeb40b0c9875a36b983d85f54fb7381c47c
signet (0.22.0) sha256=b76d495ccb07ad35dbc89f3e920665a9d8ed717141955034005d7843dcfe4780
trailblazer-option (0.1.2) sha256=20e4f12ea4e1f718c8007e7944ca21a329eee4eed9e0fa5dde6e8ad8ac4344a3
uber (0.1.0) sha256=5beeb407ff807b5db994f82fa9ee07cfceaa561dad8af20be880bc67eba935dc
uri (1.1.1) sha256=379fa58d27ffb1387eaada68c749d1426738bd0f654d812fcc07e7568f5c57c6
yard (0.9.44) sha256=eb087e9b631ccd887b049f303d489963945452d5e2a7eb49a5a74a7cf6887f28

BUNDLED WITH
4.0.14
Original file line number Diff line number Diff line change
Expand Up @@ -33,13 +33,19 @@ class AccessConfig
# @return [Array<Google::Apis::ManagedkafkaV1::NetworkConfig>]
attr_accessor :network_configs

# The configuration for a public Kafka cluster
# Corresponds to the JSON property `publicClusterConfig`
# @return [Google::Apis::ManagedkafkaV1::PublicClusterConfig]
attr_accessor :public_cluster_config

def initialize(**args)
update!(**args)
end

# Update properties of this object
def update!(**args)
@network_configs = args[:network_configs] if args.key?(:network_configs)
@public_cluster_config = args[:public_cluster_config] if args.key?(:public_cluster_config)
end
end

Expand Down Expand Up @@ -186,6 +192,26 @@ def update!(**args)
end
end

# Capacity configuration at a per-broker level within the Kafka cluster. The
# config will be appled to each broker in the cluster.
class BrokerCapacityConfig
include Google::Apis::Core::Hashable

# Optional. The disk to provision for each broker in Gibibytes. Minimum: 100 GiB.
# Corresponds to the JSON property `diskSizeGib`
# @return [Fixnum]
attr_accessor :disk_size_gib

def initialize(**args)
update!(**args)
end

# Update properties of this object
def update!(**args)
@disk_size_gib = args[:disk_size_gib] if args.key?(:disk_size_gib)
end
end

# Details of a broker in the Kafka cluster.
class BrokerDetails
include Google::Apis::Core::Hashable
Expand Down Expand Up @@ -347,6 +373,23 @@ def update!(**args)
class Cluster
include Google::Apis::Core::Hashable

# Output only. The bootstrap address of the Kafka cluster. The returned address
# format is: `bootstrap-...managedkafka.s.cloud.goog` or `bootstrap...
# managedkafka..cloud.goog` (legacy format). ## Examples: `bootstrap-
# nol2mecj8p94jhx2ge2rg54579a.c0aad26f.europe-west1.managedkafka.s.cloud.goog` -
# `bootstrap.my-cluster.us-central1.managedkafka.my-project.cloud.goog` The port
# number is omitted so clients can connect to their target listener (for example,
# `:9092` for TLS or `:9094` for mTLS).
# Corresponds to the JSON property `bootstrapAddress`
# @return [String]
attr_accessor :bootstrap_address

# Capacity configuration at a per-broker level within the Kafka cluster. The
# config will be appled to each broker in the cluster.
# Corresponds to the JSON property `brokerCapacityConfig`
# @return [Google::Apis::ManagedkafkaV1::BrokerCapacityConfig]
attr_accessor :broker_capacity_config

# Output only. Only populated when FULL view is requested. Details of each
# broker in the cluster.
# Corresponds to the JSON property `brokerDetails`
Expand All @@ -363,6 +406,12 @@ class Cluster
# @return [String]
attr_accessor :create_time

# Describes the effective capacity configuration of a Kafka cluster, both
# cluster-wide and per-broker.
# Corresponds to the JSON property `effectiveCapacityConfig`
# @return [Google::Apis::ManagedkafkaV1::EffectiveCapacityConfig]
attr_accessor :effective_capacity_config

# Configuration properties for a Kafka cluster deployed to Google Cloud Platform.
# Corresponds to the JSON property `gcpConfig`
# @return [Google::Apis::ManagedkafkaV1::GcpConfig]
Expand All @@ -385,6 +434,11 @@ class Cluster
# @return [String]
attr_accessor :name

# Details of the public cluster feature for the Kafka cluster.
# Corresponds to the JSON property `publicClusterDetails`
# @return [Google::Apis::ManagedkafkaV1::PublicClusterDetails]
attr_accessor :public_cluster_details

# Defines rebalancing behavior of a Kafka cluster.
# Corresponds to the JSON property `rebalanceConfig`
# @return [Google::Apis::ManagedkafkaV1::RebalanceConfig]
Expand Down Expand Up @@ -430,13 +484,17 @@ def initialize(**args)

# Update properties of this object
def update!(**args)
@bootstrap_address = args[:bootstrap_address] if args.key?(:bootstrap_address)
@broker_capacity_config = args[:broker_capacity_config] if args.key?(:broker_capacity_config)
@broker_details = args[:broker_details] if args.key?(:broker_details)
@capacity_config = args[:capacity_config] if args.key?(:capacity_config)
@create_time = args[:create_time] if args.key?(:create_time)
@effective_capacity_config = args[:effective_capacity_config] if args.key?(:effective_capacity_config)
@gcp_config = args[:gcp_config] if args.key?(:gcp_config)
@kafka_version = args[:kafka_version] if args.key?(:kafka_version)
@labels = args[:labels] if args.key?(:labels)
@name = args[:name] if args.key?(:name)
@public_cluster_details = args[:public_cluster_details] if args.key?(:public_cluster_details)
@rebalance_config = args[:rebalance_config] if args.key?(:rebalance_config)
@satisfies_pzi = args[:satisfies_pzi] if args.key?(:satisfies_pzi)
@satisfies_pzs = args[:satisfies_pzs] if args.key?(:satisfies_pzs)
Expand Down Expand Up @@ -885,6 +943,32 @@ def update!(**args)
end
end

# Describes the effective capacity configuration of a Kafka cluster, both
# cluster-wide and per-broker.
class EffectiveCapacityConfig
include Google::Apis::Core::Hashable

# Output only. The number of brokers in the cluster.
# Corresponds to the JSON property `brokerCount`
# @return [Fixnum]
attr_accessor :broker_count

# Output only. The disk assigned to each broker in Gibibytes.
# Corresponds to the JSON property `brokerDiskSizeGib`
# @return [Fixnum]
attr_accessor :broker_disk_size_gib

def initialize(**args)
update!(**args)
end

# Update properties of this object
def update!(**args)
@broker_count = args[:broker_count] if args.key?(:broker_count)
@broker_disk_size_gib = args[:broker_disk_size_gib] if args.key?(:broker_disk_size_gib)
end
end

# A generic empty message that you can re-use to avoid defining duplicated empty
# messages in your APIs. A typical example is to use it as the request or the
# response type of an API method. For instance: service Foo ` rpc Bar(google.
Expand Down Expand Up @@ -1491,6 +1575,61 @@ def update!(**args)
end
end

# The configuration for a public Kafka cluster
class PublicClusterConfig
include Google::Apis::Core::Hashable

# Required. The list of IPv4 ranges in CIDR notation that are allowed to connect
# to the public Kafka broker endpoints. The Kafka cluster should only be exposed
# to trusted external ranges. A maximum of 500 IP ranges can be specified and no
# single range can be larger than a `/16`. This field is required if
# PublicClusterConfig is specified.
# Corresponds to the JSON property `allowedSourceIpRanges`
# @return [Array<String>]
attr_accessor :allowed_source_ip_ranges

def initialize(**args)
update!(**args)
end

# Update properties of this object
def update!(**args)
@allowed_source_ip_ranges = args[:allowed_source_ip_ranges] if args.key?(:allowed_source_ip_ranges)
end
end

# Details of the public cluster feature for the Kafka cluster.
class PublicClusterDetails
include Google::Apis::Core::Hashable

# Output only. DNS discovery records that resolve to all of the external IP
# addresses associated with the public cluster. Used for configuring DNS-based
# egress firewall rules to a public cluster. discovery_dns_record can be added
# to this list if the cluster is scaled up. Must configure DNS based firewalls
# to resolve ALL DNS records in this list as large clusters have IP addresses
# sharded across records. Each record contains a maximum of 30 IP addresses.
# Corresponds to the JSON property `discoveryDnsRecords`
# @return [Array<String>]
attr_accessor :discovery_dns_records

# Output only. All of the external IP addresses associated with the public
# cluster used for configuring egress firewall rules to a public cluster.
# external_ip_address can be added to this list if the cluster is scaled up.
# Corresponds to the JSON property `externalIpAddresses`
# @return [Array<String>]
attr_accessor :external_ip_addresses

def initialize(**args)
update!(**args)
end

# Update properties of this object
def update!(**args)
@discovery_dns_records = args[:discovery_dns_records] if args.key?(:discovery_dns_records)
@external_ip_addresses = args[:external_ip_addresses] if args.key?(:external_ip_addresses)
end
end

# Defines rebalancing behavior of a Kafka cluster.
class RebalanceConfig
include Google::Apis::Core::Hashable
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,13 @@ module Google
module Apis
module ManagedkafkaV1
# Version of the google-apis-managedkafka_v1 gem
GEM_VERSION = "0.25.0"
GEM_VERSION = "0.26.0"

# Version of the code generator used to generate this client
GENERATOR_VERSION = "0.19.0"

# Revision of the discovery document this client was generated from
REVISION = "20260507"
REVISION = "20260827"
end
end
end
Loading
Loading