Linux command
aws-kafka 命令
文件
复制后可按需替换文件名、目录或参数。
常用示例
Create a new MSK cluster
aws kafka create-cluster --cluster-name [my-cluster] --kafka-version [3.5.1] --number-of-broker-nodes 3 --broker-node-group-info file://[broker-config.json]
List all MSK clusters
aws kafka list-clusters
Describe a cluster
aws kafka describe-cluster --cluster-arn [arn:aws:kafka:region:account:cluster/name/id]
Get bootstrap broker endpoints
aws kafka get-bootstrap-brokers --cluster-arn [arn:aws:kafka:region:account:cluster/name/id]
Update the number of brokers
aws kafka update-broker-count --cluster-arn [arn:aws:kafka:region:account:cluster/name/id] --current-version [K1234] --target-number-of-broker-nodes 6
List
aws kafka list-configurations
List compatible Kafka versions
aws kafka get-compatible-kafka-versions --cluster-arn [arn:aws:kafka:region:account:cluster/name/id]
Delete a cluster
aws kafka delete-cluster --cluster-arn [arn:aws:kafka:region:account:cluster/name/id]
说明
aws kafka is the AWS CLI interface for Amazon Managed Streaming for Apache Kafka (MSK), a fully managed service for running Apache Kafka. MSK handles cluster provisioning, configuration, patching, and monitoring while maintaining compatibility with open-source Kafka. MSK supports both provisioned and serverless deployment modes, SASL/SCRAM and IAM authentication, encryption at rest and in transit, and integration with AWS services like Lambda, Kinesis Data Firehose, and Glue.
FAQ
What is the aws-kafka command used for?
aws kafka is the AWS CLI interface for Amazon Managed Streaming for Apache Kafka (MSK), a fully managed service for running Apache Kafka. MSK handles cluster provisioning, configuration, patching, and monitoring while maintaining compatibility with open-source Kafka. MSK supports both provisioned and serverless deployment modes, SASL/SCRAM and IAM authentication, encryption at rest and in transit, and integration with AWS services like Lambda, Kinesis Data Firehose, and Glue.
How do I run a basic aws-kafka example?
Run `aws kafka create-cluster --cluster-name [my-cluster] --kafka-version [3.5.1] --number-of-broker-nodes 3 --broker-node-group-info file://[broker-config.json]` in a terminal, then adjust file names, paths, flags, or remote targets for your system.
Where can I find more aws-kafka examples?
This page includes 8 examples for aws-kafka, plus related commands for nearby Linux tasks.