paws.analytics (version 0.1.6)

kafka: Managed Streaming for Kafka

Description

Managed Streaming for Kafka

Usage

kafka(config = list())

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

create_cluster	Creates a new MSK cluster
create_configuration	Creates a new MSK configuration
delete_cluster	Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request
describe_cluster	Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request
describe_cluster_operation	Returns a description of the cluster operation specified by the ARN
describe_configuration	Returns a description of this MSK configuration
describe_configuration_revision	Returns a description of this revision of the configuration
get_bootstrap_brokers	A list of brokers that a client application can use to bootstrap
list_cluster_operations	Returns a list of all the operations that have been performed on the specified MSK cluster
list_clusters	Returns a list of all the MSK clusters in the current Region
list_configuration_revisions	Returns a list of all the MSK configurations in this Region
list_configurations	Returns a list of all the MSK configurations in this Region
list_nodes	Returns a list of the broker nodes in the cluster
list_tags_for_resource	Returns a list of the tags associated with the specified resource
tag_resource	Adds tags to the specified MSK resource
untag_resource	Removes the tags associated with the keys that are provided in the query
update_broker_count	Updates the number of broker nodes in the cluster
update_broker_storage	Updates the EBS storage associated with MSK brokers
update_cluster_configuration	Updates the cluster with the configuration that is specified in the request body

Examples

# NOT RUN {
svc <- kafka()
svc$create_cluster(
  Foo = 123
)
# }
# NOT RUN {
# }