建立 Apache Kafka 主題 - Amazon Managed Streaming for Apache Kafka
設定您的環境以建立主題建立主題並寫入資料

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

建立 Apache Kafka 主題

在此步驟中，您可以使用先前建立的用戶端機器，在無伺服器叢集上建立主題。

設定您的環境以建立主題

  • 建立主題之前，請確定您已將 AWS 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

    使用 MSK Serverless 叢集進行 IAM 身分驗證時，需要此 JAR 檔案。

  • 執行 Kafka 命令時，您可能需要確保 classpath包含 AWS 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。接著前往用戶端機器上的 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 中產生和使用資料