第 4 步:创建并写入 Apache Kafka 主题 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

第 4 步:创建并写入 Apache Kafka 主题

在此步骤中,您可以使用先前创建的客户端计算机在无服务器群集上创建主题。然后你写信给那个主题。我们用来写入主题的 Apache Kafka 命令就是一个例子。你可以尝试其他命令来写入该主题。

创建主题并向其中写入数据

  1. 在下面export将命令替换为端点使用创建集群后保存的 bootstrap-server 字符串。然后,转到kafka_2.12-2.8.1/bin在客户端计算机上启动目录,然后运行export命令。

    export BS=Endpoint
  2. 运行以下命令以在无服务器集群上创建主题。

    ./kafka-topics.sh --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6
  3. 要向新创建的主题写入数据,请运行以下命令。

    ./kafka-producer-perf-test.sh --topic msk-serverless-tutorial --throughput 2560 --num-records 153600 --record-size 4096 --producer-props bootstrap.servers=$BS acks=all --producer.config client.properties

下一步

第 5 步:删除资源