Kafka API models
- ClusterView
- Connector.Health
- Connector.Status
- TopicConfig28.CleanupPolicy
- TopicConfig28.CompressionType
- TopicConfig3.CleanupPolicy
- TopicConfig3.CompressionType
- Permission.AccessRole
- Cluster
- ClusterResources
- ClusterResources.Kafka
- ConnectionInfo
- Host
- MetricsExporterConnectionInfo
- PrivateConnectionInfo
- CreateClusterRequest
- DeleteClusterRequest
- GetClusterRequest
- ListClusterHostsRequest
- ListClusterHostsResponse
- ListClusterOperationsRequest
- ListClusterOperationsResponse
- ListClustersRequest
- ListClustersResponse
- RescheduleMaintenanceRequest
- ResetClusterCredentialsRequest
- StartClusterRequest
- StopClusterRequest
- UpdateClusterRequest
- KafkaConfig
- RestAPIConfig
- SchemaRegistryConfig
- ClusterConnection
- ClusterConnectionSpec
- Connector
- Connector.PropertiesEntry
- ConnectorConfigMirrorMaker
- ConnectorConfigMirrorMakerSpec
- ConnectorConfigS3Sink
- ConnectorConfigS3SinkSpec
- ConnectorSpec
- ConnectorSpec.PropertiesEntry
- ExternalClusterConnection
- ExternalClusterConnectionSpec
- S3Connection
- S3ConnectionSpec
- ThisCluster
- UpdateConnectorConfigMirrorMakerSpec
- UpdateConnectorConfigS3SinkSpec
- UpdateConnectorSpec
- UpdateConnectorSpec.UpdateProperties
- UpdateConnectorSpec.UpdateProperties.PropertiesEntry
- CreateConnectorMetadata
- CreateConnectorRequest
- DeleteConnectorMetadata
- DeleteConnectorRequest
- GetConnectorRequest
- ListConnectorsRequest
- ListConnectorsResponse
- PauseConnectorMetadata
- PauseConnectorRequest
- ResumeConnectorMetadata
- ResumeConnectorRequest
- UpdateConnectorMetadata
- UpdateConnectorRequest
- GetOperationRequest
- ListOperationsRequest
- ListOperationsResponse
- Topic
- TopicConfig28
- TopicConfig3
- TopicSpec
- CreateTopicRequest
- DeleteTopicRequest
- GetTopicRequest
- ListTopicsRequest
- ListTopicsResponse
- UpdateTopicRequest
- Permission
- User
- UserSpec
- CreateUserRequest
- DeleteUserRequest
- GetUserRequest
- GrantUserPermissionRequest
- ListUsersRequest
- ListUsersResponse
- RevokeUserPermissionRequest
- UpdateUserRequest
- UpdateUserRequest.UpdateSpec
- UpdateUserRequest.UpdateSpec.UpdatePermissions
- Version
- ListVersionsRequest
- ListVersionsResponse
ClusterView
Option |
Description |
CLUSTER_VIEW_INVALID |
Invalid cluster view value. |
CLUSTER_VIEW_BASIC |
Output basic information about the cluster. |
CLUSTER_VIEW_FULL |
Output full information about the cluster including allocated resources and Apache Kafka® settings. |
Connector.Health
Option |
Description |
HEALTH_INVALID |
Health of the connector is unknown. |
HEALTH_ALIVE |
Connector is running. |
HEALTH_DEAD |
Connector has failed to start. |
Connector.Status
Option |
Description |
STATUS_INVALID |
Connector state is unknown. |
STATUS_RUNNING |
Connector is running normally. |
STATUS_ERROR |
Connector has encountered a problem and cannot operate. |
STATUS_PAUSED |
Connector is paused. |
TopicConfig28.CleanupPolicy
Option |
Description |
CLEANUP_POLICY_INVALID |
|
CLEANUP_POLICY_DELETE |
|
CLEANUP_POLICY_COMPACT |
|
CLEANUP_POLICY_COMPACT_AND_DELETE |
TopicConfig28.CompressionType
Option |
Description |
COMPRESSION_TYPE_INVALID |
|
COMPRESSION_TYPE_UNCOMPRESSED |
|
COMPRESSION_TYPE_ZSTD |
|
COMPRESSION_TYPE_LZ4 |
|
COMPRESSION_TYPE_SNAPPY |
|
COMPRESSION_TYPE_GZIP |
|
COMPRESSION_TYPE_PRODUCER |
TopicConfig3.CleanupPolicy
Option |
Description |
CLEANUP_POLICY_INVALID |
|
CLEANUP_POLICY_DELETE |
|
CLEANUP_POLICY_COMPACT |
|
CLEANUP_POLICY_COMPACT_AND_DELETE |
TopicConfig3.CompressionType
Option |
Description |
COMPRESSION_TYPE_INVALID |
|
COMPRESSION_TYPE_UNCOMPRESSED |
|
COMPRESSION_TYPE_ZSTD |
|
COMPRESSION_TYPE_LZ4 |
|
COMPRESSION_TYPE_SNAPPY |
|
COMPRESSION_TYPE_GZIP |
|
COMPRESSION_TYPE_PRODUCER |
Permission.AccessRole
Each role abstracts away multiple operations
Option |
Description |
ACCESS_ROLE_INVALID |
|
ACCESS_ROLE_PRODUCER |
Grants describe, read and write topic operations |
ACCESS_ROLE_CONSUMER |
Grants describe and read topic operations |
ACCESS_ROLE_ADMIN |
Grants full access, including describe, read, write, manage and delete topic |
Cluster
Field |
Description |
|
string ID of the Apache Kafka® cluster. |
|
string ID of the project that the Apache Kafka® cluster belongs to. |
|
string Type of the cloud where instances should be hosted. |
|
string ID of the region to place instances. |
|
google.protobuf.Timestamp Creation timestamp. |
|
string Name of the Apache Kafka® cluster. The name is unique within the project. |
|
string Description of the Apache Kafka® cluster. |
|
doublecloud.v1.ClusterStatus Current state of the cluster. |
|
string Version of Apache Kafka®. |
|
doublecloud.kafka.v1.ClusterResources Resources allocated to the Apache Kafka® cluster. |
|
doublecloud.kafka.v1.ConnectionInfo Connection information. |
|
doublecloud.v1.Access Access settings |
|
doublecloud.v1.DataEncryption DataEncryption settings |
|
string ID of the network that the Apache Kafka® cluster belongs to. |
|
doublecloud.kafka.v1.PrivateConnectionInfo Private connection information. |
|
doublecloud.v1.MaintenanceWindow Window of maintenance operations. |
|
doublecloud.v1.MaintenanceOperation Maintenance operation planned at nearest maintenance_window. |
|
doublecloud.kafka.v1.KafkaConfig Configuration of the Apache Kafka cluster. |
|
doublecloud.kafka.v1.MetricsExporterConnectionInfo Prometheus metrics exporter endpoint HTTP basic auth information. |
|
doublecloud.kafka.v1.SchemaRegistryConfig Configuration of Schema Registry. |
|
doublecloud.kafka.v1.RestAPIConfig Configuration of REST API. |
ClusterResources
Field |
Description |
|
doublecloud.kafka.v1.ClusterResources.Kafka Resources allocated to Apache Kafka® hosts. |
ClusterResources.Kafka
Field |
Description |
|
string ID of the preset for computational resources available to a host (CPU, memory etc.). Means the minimal resource preset for autoscaling. |
|
google.protobuf.Int64Value Volume of the storage available to a host, in bytes. |
|
google.protobuf.Int64Value The number of Kafka brokers deployed in each availability zone. |
|
google.protobuf.Int64Value The number of availability zones where Kafka brokers reside. |
|
google.protobuf.Int64Value Limit for automatical storage volume scale, in bytes. Autoscaling disabled if not set. |
|
google.protobuf.StringValue Lower limit for automatical resource preset scale. Equal to resource_preset_id on creation if not set. |
|
google.protobuf.StringValue Upper limit for automatical resource preset scale. Autoscaling disabled if not set. |
ConnectionInfo
Field |
Description |
|
string String to use in clients. |
|
string Apache Kafka® user. |
|
string Password for Apache Kafka® user. |
Host
Field |
Description |
|
string Required. Name of the host. |
|
string Required. ID of the Apache Kafka® cluster. |
|
doublecloud.v1.HostStatus Aggregated host status |
MetricsExporterConnectionInfo
Field |
Description |
|
string User for HTTP basic auth. |
|
string Password for HTTP basic auth. |
PrivateConnectionInfo
Field |
Description |
|
string String to use in clients. |
|
string Apache Kafka® user. |
|
string Password for Apache Kafka® user. |
CreateClusterRequest
Field |
Description |
|
string ID of the project to create the Apache Kafka® cluster in. |
|
string Type of the cloud where instances should be hosted. |
|
string ID of the region to place instances. |
|
string Name of the Apache Kafka® cluster. The name must be unique within the project. |
|
string Description of the Apache Kafka® cluster. |
|
string Version of Apache Kafka®. |
|
doublecloud.kafka.v1.ClusterResources Resources allocated to the Apache Kafka® cluster. |
|
doublecloud.v1.Access Access settings |
|
doublecloud.v1.DataEncryption DataEncryption settings |
|
string ID of the network to create the Apache Kafka® cluster in. |
|
doublecloud.v1.MaintenanceWindow Window of maintenance operations. |
|
doublecloud.kafka.v1.KafkaConfig Configuration and resources for hosts that should be created for the Apache Kafka® cluster. |
|
doublecloud.kafka.v1.SchemaRegistryConfig Configuration of Schema Registry. |
|
doublecloud.kafka.v1.RestAPIConfig Configuration of REST API. |
DeleteClusterRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to delete. To get the Apache Kafka® cluster ID, use a [ClusterService.List] request. |
GetClusterRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster resource to return. |
|
bool Whether to include sensitive data in the response. If unspecified, defaults to false. |
ListClusterHostsRequest
Field |
Description |
|
string ID of the Apache Kafka cluster. To get the Apache Kafka cluster ID use a [ClusterService.List] request. |
|
doublecloud.v1.Paging Paging information of the request |
ListClusterHostsResponse
Field |
Description |
|
list List of Host resources. |
|
|
|
doublecloud.v1.NextPage Pagination information of the response |
ListClusterOperationsRequest
Field |
Description |
|
string Required. ID of the Kafka cluster. |
|
doublecloud.v1.Paging Paging information of the request |
ListClusterOperationsResponse
Field |
Description |
|
list |
|
|
|
doublecloud.v1.NextPage Pagination information of the response |
ListClustersRequest
Field |
Description |
|
string ID of the project to list Apache Kafka® clusters in. |
|
doublecloud.v1.Paging Paging information of the request |
|
doublecloud.kafka.v1.ClusterView The level of detail to be returned. If unspecified, defaults to CLUSTER_VIEW_BASIC. |
ListClustersResponse
Field |
Description |
|
list List of Apache Kafka® cluster resources. |
|
|
|
doublecloud.v1.NextPage Pagination information of the response |
RescheduleMaintenanceRequest
Field |
Description |
|
string Required. ID of the Kafka cluster to maintenance reschedule. |
|
doublecloud.v1.RescheduleType Required. The type of reschedule request. |
|
google.protobuf.Timestamp The time for SPECIFIC_TIME reschedule. Limited by two weeks since first time scheduled. |
ResetClusterCredentialsRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to reset credentials. To get the Apache Kafka® cluster ID, use a [ClusterService.List] request. |
StartClusterRequest
Field |
Description |
|
string ID of the Kafka cluster to start. |
StopClusterRequest
Field |
Description |
|
string ID of the Kafka cluster to stop. |
UpdateClusterRequest
Field |
Description |
|
string ID of the Apache Kafka Cluster resource to update. To get the Apache Kafka cluster ID, use a [ClusterService.List] request. |
|
string New name of the Apache Kafka® cluster. The name must be unique within the project. |
|
string New description of the Apache Kafka cluster. |
|
string Version of Apache Kafka®. |
|
doublecloud.kafka.v1.ClusterResources New resources allocated to the Apache Kafka® cluster. |
|
doublecloud.v1.Access Access settings |
|
doublecloud.v1.MaintenanceWindow Window of maintenance operations. |
|
doublecloud.kafka.v1.KafkaConfig Configuration and resources for hosts that should be created for the Apache Kafka® cluster. |
|
doublecloud.kafka.v1.SchemaRegistryConfig Configuration of Schema Registry. |
|
doublecloud.kafka.v1.RestAPIConfig Configuration of REST API. |
KafkaConfig
Field |
Description |
|
google.protobuf.Int64Value The largest record batch size allowed by Kafka. Default value: 1048588. |
|
google.protobuf.Int64Value The number of bytes of messages to attempt to fetch for each partition. Default value: 1048576. |
|
google.protobuf.Int64Value The maximum size of the log before deleting it. Default is -1. |
|
google.protobuf.Int64Value The number of hours to keep a log file before deleting it (in hours), tertiary to log.retention.ms property. Default: 168 hours. |
|
google.protobuf.Int64Value The number of minutes to keep a log file before deleting it (in minutes), secondary to log.retention.ms property. If not set, the value in log.retention.hours is used. |
|
google.protobuf.Int64Value The number of milliseconds to keep a log file before deleting it (in milliseconds), If not set, the value in log.retention.minutes is used. If set to -1, no time limit is applied. |
RestAPIConfig
Field |
Description |
|
bool Is REST API enabled for this cluster. |
SchemaRegistryConfig
Field |
Description |
|
bool Is Schema Registry enabled for this cluster. |
ClusterConnection
Field |
Description |
|
string
Alias of cluster connection configuration.
Examples: |
|
one of: |
|
doublecloud.kafka.v1.ThisCluster Connection configuration of the cluster the connector belongs to. As all credentials are already known, leave this parameter empty. |
|
doublecloud.kafka.v1.ExternalClusterConnection Configuration of connection to an external cluster with all the necessary credentials. |
ClusterConnectionSpec
Field |
Description |
|
google.protobuf.StringValue
Alias of cluster connection configuration.
Examples: |
|
one of: |
|
doublecloud.kafka.v1.ThisCluster Connection configuration of the cluster the connector belongs to. As all credentials are already known, leave this parameter empty. |
|
doublecloud.kafka.v1.ExternalClusterConnectionSpec Configuration of connection to an external cluster with all the necessary credentials. |
Connector
Field |
Description |
|
string Name of the connector. |
|
google.protobuf.Int64Value Maximum number of connector tasks. Default value is the number of brokers. |
|
list
A set of properties passed to Managed Service for Apache Kafka® with the
connector configuration.
Example: |
|
|
|
doublecloud.kafka.v1.Connector.Health Connector health. |
|
doublecloud.kafka.v1.Connector.Status Current status of the connector. |
|
string ID of the Apache Kafka® cluster that the connector belongs to. |
|
one of: |
|
doublecloud.kafka.v1.ConnectorConfigMirrorMaker Configuration of the MirrorMaker connector. |
|
doublecloud.kafka.v1.ConnectorConfigS3Sink Configuration of S3-Sink connector. |
Connector.PropertiesEntry
Field |
Description |
|
string |
|
string |
ConnectorConfigMirrorMaker
Field |
Description |
|
doublecloud.kafka.v1.ClusterConnection Source cluster connection configuration. |
|
doublecloud.kafka.v1.ClusterConnection Target cluster connection configuration. |
|
string
List of Kafka topics, separated by |
|
google.protobuf.Int64Value Replication factor for automatically created topics. |
ConnectorConfigMirrorMakerSpec
Field |
Description |
|
doublecloud.kafka.v1.ClusterConnectionSpec Source cluster configuration for the MirrorMaker connector. |
|
doublecloud.kafka.v1.ClusterConnectionSpec Target cluster configuration for the MirrorMaker connector. |
|
string
List of Kafka topics, separated by |
|
google.protobuf.Int64Value Replication factor for automatically created topics. |
ConnectorConfigS3Sink
Field |
Description |
|
string List of Kafka topics, separated by ','. |
|
string
The compression type used for files put on S3.
The supported values are: |
|
google.protobuf.Int64Value Max records per file. |
|
doublecloud.kafka.v1.S3Connection Credentials for connecting to S3 storage. |
ConnectorConfigS3SinkSpec
Field |
Description |
|
string List of Kafka topics, separated by ','. |
|
string
The compression type used for files put on S3.
The supported values are: |
|
google.protobuf.Int64Value Max records per file. |
|
doublecloud.kafka.v1.S3ConnectionSpec Credentials for connecting to S3 storage. |
ConnectorSpec
Field |
Description |
|
string Name of the connector. |
|
google.protobuf.Int64Value Maximum number of connector tasks. Default value is the number of brokers. |
|
list
A set of properties passed to Managed Service for Apache Kafka® with the
connector configuration.
Example: |
|
|
|
one of: |
|
doublecloud.kafka.v1.ConnectorConfigMirrorMakerSpec Configuration of the MirrorMaker connector. |
|
doublecloud.kafka.v1.ConnectorConfigS3SinkSpec Configuration of S3-Sink connector. |
ConnectorSpec.PropertiesEntry
Field |
Description |
|
string |
|
string |
ExternalClusterConnection
Field |
Description |
|
string
List of bootstrap servers of the cluster, separated by |
|
string SASL username to use for connection to the cluster. |
|
string SASL mechanism to use for connection to the cluster. |
|
string Security protocol to use for connection to the cluster. |
ExternalClusterConnectionSpec
Field |
Description |
|
google.protobuf.StringValue
List of bootstrap servers of the cluster, separated by |
|
google.protobuf.StringValue SASL username to use for connection to the cluster. |
|
google.protobuf.StringValue SASL password to use for connection to the cluster. |
|
google.protobuf.StringValue SASL mechanism to use for connection to the cluster. |
|
google.protobuf.StringValue Security protocol to use for connection to the cluster. |
|
google.protobuf.StringValue CA in PEM format to connect to external cluster. Lines of certificate separated by '\n' symbol. |
S3Connection
Field |
Description |
|
string |
|
string |
|
string |
|
string Default is 'us-east-1' |
S3ConnectionSpec
Field |
Description |
|
google.protobuf.StringValue |
|
google.protobuf.StringValue |
|
google.protobuf.StringValue |
|
google.protobuf.StringValue |
|
google.protobuf.StringValue Default is 'us-east-1'. |
ThisCluster
Field |
Description |
UpdateConnectorConfigMirrorMakerSpec
Field |
Description |
|
doublecloud.kafka.v1.ClusterConnectionSpec Source cluster configuration for the MirrorMaker connector. |
|
doublecloud.kafka.v1.ClusterConnectionSpec Target cluster configuration for the MirrorMaker connector. |
|
google.protobuf.StringValue List of Kafka topics, separated by ','. |
|
google.protobuf.Int64Value Replication factor for automatically created topics. |
UpdateConnectorConfigS3SinkSpec
Field |
Description |
|
google.protobuf.StringValue List of Kafka topics, separated by ','. |
|
google.protobuf.Int64Value Max records per file. |
|
doublecloud.kafka.v1.S3ConnectionSpec Credentials for connecting to S3 storage. |
UpdateConnectorSpec
Field |
Description |
|
google.protobuf.Int64Value Maximum number of connector tasks to update. Nil value is ignored and considered as non-set value. |
|
doublecloud.kafka.v1.UpdateConnectorSpec.UpdateProperties When provided, current properties will be replaced. See [UpdateProperties.properties] for details. |
|
one of: |
|
doublecloud.kafka.v1.UpdateConnectorConfigMirrorMakerSpec Configuration of the MirrorMaker connector. |
|
doublecloud.kafka.v1.UpdateConnectorConfigS3SinkSpec Update specification for S3-Sink Connector. |
UpdateConnectorSpec.UpdateProperties
Field |
Description |
|
list New set of properties for the connector. Empty slice will remove all existing the properties. |
|
doublecloud.kafka.v1.UpdateConnectorSpec.UpdateProperties.PropertiesEntry |
UpdateConnectorSpec.UpdateProperties.PropertiesEntry
Field |
Description |
|
string |
|
string |
CreateConnectorMetadata
Field |
Description |
|
string ID of the Apache Kafka® cluster the connector is being created in. |
|
string Name of the Apache Kafka® connector that is being created. |
CreateConnectorRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to create the connector in. To get this ID, make a [ClusterService.List] request. |
|
doublecloud.kafka.v1.ConnectorSpec Configuration of the connector to create. |
DeleteConnectorMetadata
Field |
Description |
|
string ID of the Apache Kafka® cluster the connector is being deleted from. |
|
string Name of the Apache Kafka® connector that is being deleted. |
DeleteConnectorRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to delete the connector from. To get this ID, make a [ClusterService.List] request. |
|
string Name of the connector to delete. To get this name, make a [ConnectorService.List] request. |
GetConnectorRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster the connector belongs to. To get this ID, make a [ClusterService.List] request. |
|
string Name of the Apache Kafka® connector to return information about. To get this name, make a [ConnectorService.List] request. |
ListConnectorsRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to list connectors in. To get this ID, make a [ClusterService.List] request. |
|
doublecloud.v1.Paging Paging information of the request. See [doublecloud.priv.v1.Paging] for details Following constraints applied:
|
ListConnectorsResponse
Field |
Description |
|
list List of Apache Kafka® Connectors. |
|
|
|
doublecloud.v1.NextPage Pagination information of the response See [doublecloud.priv.v1.NextPage] for details |
PauseConnectorMetadata
Field |
Description |
|
string ID of the Apache Kafka® cluster the connector is being paused in. |
|
string Name of the Apache Kafka® connector that is being paused. |
PauseConnectorRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to pause the connector in. To get this ID, make a [ClusterService.List] request. |
|
string Name of the Apache Kafka® connector to pause. To get this name, make a [ConnectorService.List] request. |
ResumeConnectorMetadata
Field |
Description |
|
string ID of the Apache Kafka® cluster the connector is being resumed in. |
|
string Name of the Apache Kafka® connector that is beign resumed. |
ResumeConnectorRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to resume the connector in. To get this ID, make a [ClusterService.List] request. |
|
string Name of the Apache Kafka® connector to resume. To get this name, make a [ConnectorService.List] request. |
UpdateConnectorMetadata
Field |
Description |
|
string ID of the Apache Kafka® cluster the connector is being updated in. |
|
string Name of the Apache Kafka® connector that is being updated. |
UpdateConnectorRequest
Field |
Description |
|
string ID of the Apache Kafka® cluster to update the connector in. To get this ID, make a [ClusterService.List] request. |
|
string Name of the connector to update. To get this name, make a [ConnectorService.List] request. |
|
doublecloud.kafka.v1.UpdateConnectorSpec Configuration of the connector to update. |
GetOperationRequest
Field |
Description |
|
string Required. ID of the operation to return. |
ListOperationsRequest
Field |
Description |
|
string ID of the project to list clusters operations in. |
|
doublecloud.v1.Paging Paging information of the request |
ListOperationsResponse
Field |
Description |
|
list List of operations. |
|
|
|
doublecloud.v1.NextPage Pagination information of the response |
Topic
Field |
Description |
|
string Name of the topic. |
|
string ID of the Apache Kafka cluster that the topic belongs to. |
|
google.protobuf.Int64Value Number of topic partitions. |
|
google.protobuf.Int64Value Amount of copies of a topic data kept in a cluster. |
|
one of: |
|
|
|
|
|
bool True if topic has SLA guaranties |
TopicConfig28
Field |
Description |
|
doublecloud.kafka.v1.TopicConfig28.CleanupPolicy Retention policy to use on old log segments. |
|
doublecloud.kafka.v1.TopicConfig28.CompressionType Specify the final compression type for a given topic. |
|
google.protobuf.Int64Value This configuration controls the maximum size a partition (which consists of log segments) can grow to before we will discard old log segments to free up space if we are using the "delete" retention policy |
|
google.protobuf.Int64Value This configuration controls the maximum time we will retain a log before we will discard old log segments to free up space if we are using the "delete" retention policy. |
|
google.protobuf.Int64Value The largest record batch size allowed in topic. |
TopicConfig3
Field |
Description |
|
doublecloud.kafka.v1.TopicConfig3.CleanupPolicy Retention policy to use on old log segments. |
|
doublecloud.kafka.v1.TopicConfig3.CompressionType Specify the final compression type for a given topic. |
|
google.protobuf.Int64Value This configuration controls the maximum size a partition (which consists of log segments) can grow to before we will discard old log segments to free up space if we are using the "delete" retention policy |
|
google.protobuf.Int64Value This configuration controls the maximum time we will retain a log before we will discard old log segments to free up space if we are using the "delete" retention policy. |
|
google.protobuf.Int64Value The largest record batch size allowed in topic. |
TopicSpec
Field |
Description |
|
string Name of the topic. |
|
google.protobuf.Int64Value Number of topic partitions |
|
google.protobuf.Int64Value Amount of copies of a topic data kept in a cluster. |
|
one of: |
|
|
|
CreateTopicRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster to create a topic in. To get the cluster ID use a [ClusterService.List] request. |
|
doublecloud.kafka.v1.TopicSpec Required. Configuration of the topic to create. |
DeleteTopicRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster to delete a topic in. To get the cluster ID, use a [ClusterService.List] request. |
|
string Required. Name of the topic to delete. To get the name of the topic, use a [TopicService.List] request. |
GetTopicRequest
Field |
Description |
|
string ID of the Apache Kafka cluster that the topic belongs to. To get the cluster ID use a [ClusterService.List] request. |
|
string Name of the Apache Kafka Topic resource to return. To get the name of the topic use a [TopicService.List] request. |
ListTopicsRequest
Field |
Description |
|
string ID of the Apache Kafka cluster to list topics in. To get the cluster ID use a [ClusterService.List] request. |
|
doublecloud.v1.Paging Paging information of the request |
ListTopicsResponse
Field |
Description |
|
list List of Apache Kafka Topic resources. |
|
|
|
doublecloud.v1.NextPage Pagination information of the response |
UpdateTopicRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster to update a topic in. To get the cluster ID use a [ClusterService.List] request. |
|
string Required. Name of the topic to update. To get the name of the topic use a [TopicService.List] request. |
|
doublecloud.kafka.v1.TopicSpec Required. Configuration of the topic to create. |
Permission
Field |
Description |
|
string Name or prefix-pattern with wildcard for the topic that the permission grants access to. Examples:
|
|
doublecloud.kafka.v1.Permission.AccessRole Access role to be granted to the user. |
User
Field |
Description |
|
string Apache Kafka User's name. For a string spec see [UserSpec.name] |
|
string Apache Kafka cluster ID the user belongs to. |
|
list Set of permissions the user is granted with. |
|
UserSpec
Field |
Description |
|
string Apache Kafka User's name. Value must be a non-empty string:
|
|
string Apache Kafka User's password Value must be a non-empty string:
|
|
list Set of permissions granted to the user. |
|
CreateUserRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster to create a user in. To get the cluster ID, use a [ClusterService.List] request. |
|
doublecloud.kafka.v1.UserSpec User creation payload. See [UserSpec] for details |
DeleteUserRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster the user belongs to. To get the cluster ID, use a [ClusterService.List] request. |
|
string Required. Name of the user to delete. To get the name of the user, use a [UserService.List] request. |
GetUserRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster the user belongs to. To get the cluster ID, use a [ClusterService.List] request. |
|
string Required. Name of the Apache Kafka User resource to return. To get the name of the user, use a [UserService.List] request. |
GrantUserPermissionRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster the user belongs to. To get the cluster ID, use a [ClusterService.List] request. |
|
string Required. Name of the user to grant the permission to. To get the name of the user, use a [UserService.List] request. |
|
doublecloud.kafka.v1.Permission Required. Permission that should be granted to the specified user. |
ListUsersRequest
Field |
Description |
|
string Required. ID of the cluster to list Apache Kafka users in. To get the cluster ID, use a [ClusterService.List] request. |
|
doublecloud.v1.Paging Paging information of the request. See [doublecloud.priv.v1.Paging] for details Following constraints applied:
|
ListUsersResponse
Field |
Description |
|
list List of Apache Kafka User resources. |
|
|
|
doublecloud.v1.NextPage Pagination information of the response See [doublecloud.priv.v1.NextPage] for details |
RevokeUserPermissionRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster the user belongs to. To get the cluster ID, use a [ClusterService.List] request. |
|
string Required. Name of the user to revoke a permission from. To get the name of the user, use a [UserService.List] request. |
|
doublecloud.kafka.v1.Permission Required. Permission that should be revoked from the specified user. |
UpdateUserRequest
Field |
Description |
|
string Required. ID of the Apache Kafka cluster the user belongs to. To get the cluster ID use a [ClusterService.List] request. |
|
string Required. Name of the user to be updated. To get the name of the user use a [UserService.List] request. |
|
doublecloud.kafka.v1.UpdateUserRequest.UpdateSpec Defines which exact attributes to be updated. |
UpdateUserRequest.UpdateSpec
Field |
Description |
|
google.protobuf.StringValue When provided, Apache Kafka User's password will be updated. Empty string is ignored and considered as non-set password value. Regular password constraints applied, see [UserSpec.password] for details. |
|
doublecloud.kafka.v1.UpdateUserRequest.UpdateSpec.UpdatePermissions When provided, current Apache Kafka User's permissions will be replaced. See [UpdatePermissions.permissions] for details. |
UpdateUserRequest.UpdateSpec.UpdatePermissions
Field |
Description |
|
list New set of permissions for the user. Empty slice will remove all existing the permissions. |
|
Version
Field |
Description |
|
string ID of the version. |
|
string Name of the version. |
|
bool Whether version is deprecated. |
|
list List of versions that can be updated from current. |
|
string |
ListVersionsRequest
Field |
Description |
|
doublecloud.v1.Paging Paging information of the request |
ListVersionsResponse
Field |
Description |
|
list Requested list of available versions. |
|
|
|
doublecloud.v1.NextPage Pagination information of the response |