aws生产实践-9：使用msk托管服务创建kafka集群

目录：

(1).创建kafka生产集群

(2).msk简单使用

(1).创建kafka生产集群

MSK 是采用的滚动升级的方式 版本升级过程中是可以继续使用的。

https://ap-northeast-1.console.aws.amazon.com/msk/home?region=ap-northeast-1#/home

定价：

https://ap-northeast-1.console.aws.amazon.com/msk/home?region=ap-northeast-1#/cluster/arn%3Aaws%3Akafka%3Aap-northeast-1%3A332170830573%3Acluster%2Fkafka-biz-cluster%2F797f0e7c-aa9c-4df7-b01c-1081305d8905-3/view?tabId=details

(2).msk简单使用

kafka创建topic：

https://docs.aws.amazon.com/zh_cn/msk/latest/developerguide/create-topic.html

sudo yum install -y java-1.8.0

wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz

tar -xzf kafka_2.12-2.2.1.tgz

对msk进行操作要做aws configure认证：

获取kafka相关信息：

aws kafka describe-cluster --cluster-arn kafka-arn --region ap-northeast-1

查出来topic：

"ZookeeperConnectString": xxxxxx

然后就可以进行创建topic的操作：

bin/kafka-topics.sh --create --zookeeper "xxxxxx" --replication-factor 2 --partitions 30 --topic test

查看所有topic：

bin/kafka-topics.sh --zookeeper "xxxxxx" --list

删除topic

bin/kafka-topics.sh --delete --zookeeper "xxxxxx" --topic test

删除消费组

bin/kafka-consumer-groups.sh --bootstrap-server "kafka实例端口" --delete --group test_group