Learn R Programming

paws (version 0.1.12)

kafka: Managed Streaming for Kafka

Description

The operations for managing an Amazon MSK cluster.

Usage

kafka(config = list())

Value

A client for the service. You can call the service's operations using syntax like svc$operation(...), where svc is the name you've assigned to the client. The available operations are listed in the Operations section.

Arguments

config

Optional configuration of credentials, endpoint, and/or region.

Service syntax

svc <- kafka(
  config = list(
    credentials = list(
      creds = list(
        access_key_id = "string",
        secret_access_key = "string",
        session_token = "string"
      ),
      profile = "string"
    ),
    endpoint = "string",
    region = "string"
  )
)

Operations

batch_associate_scram_secretAssociates one or more Scram Secrets with an Amazon MSK cluster
batch_disassociate_scram_secretDisassociates one or more Scram Secrets from an Amazon MSK cluster
create_clusterCreates a new MSK cluster
create_configurationCreates a new MSK configuration
delete_clusterDeletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request
delete_configurationDeletes an MSK Configuration
describe_clusterReturns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request
describe_cluster_operationReturns a description of the cluster operation specified by the ARN
describe_configurationReturns a description of this MSK configuration
describe_configuration_revisionReturns a description of this revision of the configuration
get_bootstrap_brokersA list of brokers that a client application can use to bootstrap
get_compatible_kafka_versionsGets the Apache Kafka versions to which you can update the MSK cluster
list_cluster_operationsReturns a list of all the operations that have been performed on the specified MSK cluster
list_clustersReturns a list of all the MSK clusters in the current Region
list_configuration_revisionsReturns a list of all the MSK configurations in this Region
list_configurationsReturns a list of all the MSK configurations in this Region
list_kafka_versionsReturns a list of Kafka versions
list_nodesReturns a list of the broker nodes in the cluster
list_scram_secretsReturns a list of the Scram Secrets associated with an Amazon MSK cluster
list_tags_for_resourceReturns a list of the tags associated with the specified resource
reboot_brokerReboots brokers
tag_resourceAdds tags to the specified MSK resource
untag_resourceRemoves the tags associated with the keys that are provided in the query
update_broker_countUpdates the number of broker nodes in the cluster
update_broker_storageUpdates the EBS storage associated with MSK brokers
update_cluster_configurationUpdates the cluster with the configuration that is specified in the request body
update_cluster_kafka_versionUpdates the Apache Kafka version for the cluster
update_configurationUpdates an MSK configuration
update_monitoringUpdates the monitoring settings for the cluster

Examples

Run this code
if (FALSE) {
svc <- kafka()
svc$batch_associate_scram_secret(
  Foo = 123
)
}

Run the code above in your browser using DataLab