本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
Amazon MSK 配置操作
本主题说明如何创建自定义 MSK 配置以及如何对这些配置执行操作。有关如何使用 MSK 配置创建或更新集群的信息,请参阅 Amazon MSK:工作原理。
创建 MSK 配置
-
创建一个文件,可在其中指定要设置的配置属性以及要分配给这些属性的值。以下是示例配置文件的内容。
auto.create.topics.enable = true zookeeper.connection.timeout.ms = 1000 log.roll.ms = 604800000
-
运行以下Amazon CLI命令,并
config-file-path
替换为在上一步中保存配置的文件的路径。注意 您为配置选择的名称必须符合以下正则表达式:"^[0-9A-Za-z][0-9A-Za-z-]{0,}$"。
aws kafka create-configuration --name "ExampleConfigurationName" --description "Example configuration description." --kafka-versions "1.1.1" --server-properties fileb://
config-file-path
以下是运行此命令后的成功响应示例。
{ "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "CreationTime": "2019-05-21T19:37:40.626Z", "LatestRevision": { "CreationTime": "2019-05-21T19:37:40.626Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "ExampleConfigurationName" }
-
上面的命令为您的新配置返回 Amazon Resource (ARN)。保存此 ARN,因为您需要使用它来在其他命令中引用此配置。如果您丢失了配置 ARN,则可以列出账户中的所有配置以便再次查找。
更新 MSK 配置
-
创建一个文件,在其中指定要更新的配置属性和要为其分配的值。以下是示例配置文件的内容。
auto.create.topics.enable = true zookeeper.connection.timeout.ms = 1000 min.insync.replicas = 2
-
运行以下Amazon CLI命令,并
config-file-path
替换为在上一步中保存配置的文件的路径。将 c
onfiguration-
arn 替换为您在创建配置时获得的 ARN。如果您在创建配置时没有保存 ARN,则可以使用list-configurations
命令列出账户中的所有配置。列表中所需的配置将显示在响应中。配置的 ARN 也将显示在该列表中。aws kafka update-configuration --arn
configuration-arn
--description "Example configuration revision description." --server-propertiesfileb://config-file-path
-
以下是运行此命令后的成功响应示例。
{ "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "LatestRevision": { "CreationTime": "2020-08-27T19:37:40.626Z", "Description": "Example configuration revision description.", "Revision": 2 } }
删除 MSK 配置
以下程序显示如何删除未附加到集群的配置。您无法删除连接到集群的配置。
-
要运行此示例,请将 c
onfiguration-
arn 替换为您在创建配置时获得的 ARN。如果您在创建配置时没有保存 ARN,则可以使用list-configurations
命令列出账户中的所有配置。列表中所需的配置将显示在响应中。配置的 ARN 也将显示在该列表中。aws kafka delete-configuration --arn
configuration-arn
-
以下是运行此命令后的成功响应示例。
{ "arn": " arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "state": "DELETING" }
描述 MSK 配置
-
以下命令返回有关配置的元数据。要获取配置的详细说明,请运行
describe-configuration-revision
。要运行此示例,请将 c
onfiguration-
arn 替换为您在创建配置时获得的 ARN。如果您在创建配置时没有保存 ARN,则可以使用list-configurations
命令列出账户中的所有配置。列表中所需的配置将显示在响应中。配置的 ARN 也将显示在该列表中。aws kafka describe-configuration --arn
configuration-arn
-
以下是运行此命令后的成功响应示例。
{ "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "SomeTest" }
描述 MSK 配置修订
如果您使用describe-configuration
命令来描述 MSK 配置,则会看到配置的元数据。要获取对配置的描述,请使用命令,describe-configuration-revision
。
-
运行以下命令并将 con
figuration-
arn 替换为您在创建配置时获得的 ARN。如果您在创建配置时没有保存 ARN,则可以使用list-configurations
命令列出账户中的所有配置。您在响应中显示的列表中想要的配置。配置的 ARN 也将显示在该列表中。aws kafka describe-configuration-revision --arn
configuration-arn
--revision 1以下是运行此命令后的成功响应示例。
{ "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1, "ServerProperties": "YXV0by5jcmVhdGUudG9waWNzLmVuYWJsZSA9IHRydWUKCgp6b29rZWVwZXIuY29ubmVjdGlvbi50aW1lb3V0Lm1zID0gMTAwMAoKCmxvZy5yb2xsLm1zID0gNjA0ODAwMDAw" }
的值
ServerProperties
是使用 base64 编码的。如果您使用 base64 解码器(例如 https://www.base64decode.org/)对其进行手动解码,则会获得用于创建自定义配置的原始配置文件的内容。在此情况下,您将获得以下内容:auto.create.topics.enable = true zookeeper.connection.timeout.ms = 1000 log.roll.ms = 604800000
列出您的账户中当前区域的所有 MSK 配置
-
运行以下命令。
aws kafka list-configurations
以下是运行此命令后的成功响应示例。
{ "Configurations": [ { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "SomeTest" }, { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "CreationTime": "2019-05-03T23:08:29.446Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-03T23:08:29.446Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "ExampleConfigurationName" } ] }