创建 Apache Kafka 主题 - Amazon Managed Streaming for Apache Kafka
设置用于创建主题的环境创建主题并向其写入数据
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

创建 Apache Kafka 主题

在此步骤中，您将使用先前创建的客户端计算机在无服务器集群上创建主题。

设置用于创建主题的环境

  • 在创建主题之前，请确保您已将 Amazon MSK IAM JAR 文件下载到 Kafka 安装的libs/目录中。如果您尚未执行此操作，请在 Kafka 的libs/目录中运行以下命令。

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar

    此 JAR 文件是您的 MSK 无服务器集群的 IAM 身份验证所必需的。

  • 运行 Kafka 命令时，你可能需要确保classpath包含 Amazon MSK IAM JAR 文件。为此，请执行以下操作之一：

    • 将CLASSPATH环境变量设置为包含您的 Kafka 库，如以下示例所示。

      export CLASSPATH=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar

    • 使用完整的 Java 命令和显式命令运行 Kafka 命令classpath，如以下示例所示。

      java -cp "<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.TopicCommand --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

创建主题并向其写入数据

  1. 在以下export命令中，my-endpoint替换为在创建集群后保存的 bootstrap-server 字符串。然后，转到客户端计算机上的 kafka_2.12-2.8.1/bin 目录并运行 export 命令。

    export BS=my-endpoint

  2. 运行以下命令以创建名为 msk-serverless-tutorial 的主题。

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

下一步

在 MSK Serverless 中生成和使用数据