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

# 创建客户端计算机和 Apache Kafka 主题
<a name="mkc-create-topic"></a>

在此步骤中，您需创建 Amazon EC2 实例以用作 Apache Kafka 客户端实例。然后，您可以使用此实例在集群上创建主题。

**创建客户端计算机**

1. 打开位于 [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/) 的 Amazon EC2 控制台。

1. 选择 **Launch instances**。

1. 输入客户端计算机的**名称**，例如 **mkc-tutorial-client**。

1. 对于**亚马逊机器映像（AMI）类型**，始终选中 **Amazon Linux 2 AMI（HVM）– 内核 5.10，SSD 卷类型**。

1. 选择 **t2.xlarge** 实例类型。

1. 在**密钥对（登录）**下，选择**创建新密钥对**。为**密钥对名称**输入 **mkc-tutorial-key-pair**，然后选择**下载密钥对**。此外，您还可使用现有密钥对。

1. 选择**启动实例**。

1. 选择**查看实例**。然后，在**安全组**列中，选择与新的实例关联的安全组。复制并保存安全组的 ID，以供稍后使用。

**允许新创建的客户端向集群发送数据**

1. 打开位于 [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/) 的 Amazon VPC 控制台。

1. 在左侧窗格的**安全性**下，选择**安全组**。在**安全组 ID** 列中，找到集群的安全组。您在 [设置 MSK Connect 所需的资源](mkc-tutorial-setup.md) 中创建集群时保存了该安全组的 ID。通过选中该安全组行左侧的复选框来选择该安全组。确保没有同时选择其他安全组。

1. 在屏幕的下半部分，选择**入站规则**选项卡。

1. 选择**编辑入站规则**。

1. 在屏幕的左下角，选择**添加规则**。

1. 在新规则中，选择**类型**列中的**所有流量**。在**源**列右侧的字段中，输入客户端计算机的安全组 ID。这是您在创建客户端计算机后保存的安全组 ID。

1. 选择**保存规则**。您的 MSK 集群现在将接受来自您在上一程序中创建的客户端的所有流量。

**要创建主题，请执行以下操作**

1. 打开位于 [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/) 的 Amazon EC2 控制台。

1. 在实例表中选择 `mkc-tutorial-client`。

1. 在屏幕顶部附近，选择**连接**，然后按照说明连接到实例。

1. 通过运行以下命令在客户端实例上安装 Java：

   ```
   sudo yum install java-1.8.0
   ```

1. 运行以下命令以下载 Apache Kafka。

   ```
   wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz
   ```
**注意**  
如果您希望使用此命令中使用的镜像站点之外的镜像站点，则可在 [Apache](https://www.apache.org/dyn/closer.cgi?path=/kafka/1.1.1/kafka_2.11-1.1.1.tgz) 网站上选择其他镜像站点。

1. 在上一步中将 TAR 文件下载到的目录中运行以下命令。

   ```
   tar -xzf kafka_2.12-2.2.1.tgz
   ```

1. 转到 **kafka\$12.12-2.2.1** 目录。

1. 在[https://console.aws.amazon.com/msk/家打开亚马逊 MSK 控制台？ region=us](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/)-east-1\$1/home/。

1. 在左侧窗格中，选择**集群**，然后选择名称 `mkc-tutorial-cluster`。

1. 选择**查看客户端信息**。

1. 复制**明文**连接字符串。

1. 选择**完成**。

1. 在客户端实例 (`mkc-tutorial-client`) 上运行以下命令，*bootstrapServerString*替换为您在查看集群的客户机信息时保存的值。

   ```
   <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server bootstrapServerString --replication-factor 2 --partitions 1 --topic mkc-tutorial-topic
   ```

   如果此命令成功，您将看到以下消息：`Created topic mkc-tutorial-topic.`

**下一步**

[创建连接器](mkc-create-connector.md)