步骤 2: 使用控制台供应 Event Streams 实例

1. 登录到 IBM Cloud 控制台。

2. 单击 目录中的 Event Streams 服务。

3. 从 选择定价计划 部分中选择 轻量套餐，标准套餐或 企业套餐。

4. 输入服务的名称。 可以使用缺省值。

5. 单击创建。 此时将打开 Event Streams 资源列表 页面。

6. 创建实例后，单击实例名称以查看更多信息。

7. 可选。 您可以完成 入门教程 中的步骤来运行样本入门模板应用程序。

步骤 2: 使用 CLI 供应 Event Streams 实例

如果是首次使用 CLI，请参阅 CLI 入门。

要使用 IBM Cloud CLI 供应 Event Streams 标准套餐的实例，请完成以下步骤:

1. 通过完成 IBM Cloud CLI 入门中的步骤，安装 IBM Cloud CLI。

2. 通过运行以下命令，登录到 IBM Cloud：

   ibmcloud login -a cloud.ibm.com
   

3. 使用轻量套餐、标准套餐或企业套餐在 Event Streams 上创建 IBM Cloud 实例。

   选择下列其中一种方法：

   • 要在企业版计划中通过CLI创建实例，请运行以下命令：

     ibmcloud resource service-instance-create <INSTANCE_NAME> messagehub enterprise-3nodes-2tb <REGION>
     

     由于企业计划为每个集群分配了专用资源，因此需要更多时间进行配置，因此创建一个新的企业实例可能需要长达3个小时。

   • 要在标准套餐上通过 CLI 创建实例，请运行以下命令:

     ibmcloud resource service-instance-create <INSTANCE_NAME> messagehub standard <REGION>
     

     由于基础资源已经设置完毕，因此创建新的标准计划实例是即时的。

步骤 2: 使用资源控制器 API 供应 Event Streams 实例

供应实例的首选方法是使用 CLI。

或者，可以使用 资源控制器 API。 首先，检索访问令牌，然后使用访问令牌运行资源控制器 API 命令以 创建实例。

curl -X POST https://resource-controller.cloud.ibm.com/v2/resource_instances -H "Authorization: ${token}" -H "Content-Type: application/json" \
-d '{ "name": "JG-test-curl", "target": "us-south", "resource_group":"9eba3cff1b0540b9ab7fb93829911da0", "resource_plan_id": "ibm.message.hub.enterprise.3nodes.2tb", "parameters":{"service-endpoints":"public","throughput":"150"}}'

步骤 3: 使用控制台创建主题并选择分区数

有关创建主题时可修改的设置的指导，请参阅 主题配置。

1. 从新供应的实例中，使用左侧的菜单浏览到 主题。

2. 单击 创建主题 按钮并输入主题名称。 单击下一步。 话题名称最多只能包含200个字符。

3. 选择分区数。

   主题由一个或多个分区组成。 分区是消息的有序列表。1 分区足以开始使用，但生产系统通常具有更多功能。

   分区分布在各个经纪人之间，以增加话题的可扩展性。 您还可使用分区在使用者组的成员之间分发消息。

   单击下一步。

4. 设置信息保留期限。 这是在删除消息前，这些消息的保留时间长度。 如果在此时间内使用者未读取您的消息，那么将错过这些消息。 消息的默认保留时间为24小时。 最小值为 1 小时，最大值为 30 天。 请将此值指定为小时的倍数。

   单击 创建主题。

步骤 3: 使用 CLI 创建主题并选择分区数

有关创建主题时可修改的设置的指导，请参阅 主题配置。

使用以下 ibmcloud es topic-create 命令创建具有所选分区数的新主题:

ibmcloud es topic-create [--name] TOPIC_NAME [--partitions PARTITIONS] [--config KEY=VALUE[;KEY=VALUE]* ]*

先决条件：无

命令选项：

--name value, -n value

主题名称。 话题名称最多只能包含200个字符。

--partitions value, -p value

设置主题的分区数。

主题由一个或多个分区组成。 分区是消息的有序列表。1 分区足以开始使用，但生产系统通常具有更多功能。

分区分布在各个经纪人之间，以增加话题的可扩展性。 您还可使用分区在使用者组的成员之间分发消息。

--config KEY=VALUE, -c KEY=VALUE（可选）

将主题的配置选项设置为 KEY=VALUE 对。

可以指定多个 --config 选项。 每个“--config”选项可以指定一个以分号分隔的分配列表。 以下列表显示有效的配置密钥:

• cleanup.policy
• retention.ms
• retention.bytes
• segment.bytes
• segment.ms
• segment.index.bytes

retention.ms 键指定的消息的缺省保留期为 24 小时。 最小值为 1 小时，最大值为 30 天。 请将此值指定为小时的倍数。

ibmcloud es topics [--filter FILTER] [--json]

ibmcloud es cluster [--json]

步骤 3: 使用管理 REST API 创建主题并选择分区数

Event Streams 为可用于创建和列出主题的管理提供了 REST API。

您可以通过向 /admin/topics 路径发出 POST 请求来创建 Kafka 主题。 请求主体必须包含 JSON 文档。 例如：

{
    "name": "topicname",
    "partitions": 1,
    "configs": {
        "retentionMs": 86400000,
        "cleanupPolicy": "delete"
    }
}

JSON 文档必须包含 name 属性，并指定要创建的 Kafka 主题的名称。 主题名称限制为最多 200 个 characters.The JSON 还可以指定要分配给主题的分区数 (使用 partitions 属性)。 如果未指定分区数，那么将使用单个分区创建主题。

主题由一个或多个分区组成。 分区是消息的有序列表。1 分区足以开始使用，但生产系统通常具有更多功能。

分区分布在各个经纪人之间，以增加话题的可扩展性。 您还可使用分区在使用者组的成员之间分发消息。

您还可以在请求中指定可选的 configs 对象。 这允许您指定 retentionMs 属性，该属性控制 Kafka 保留发布到主题的消息的时间长度 (以毫秒计)。 经过此时间之后，将自动删除消息以释放空间。 必须以整数小时数 (例如，3600000 的倍数) 指定 retentionMs 属性的值。 消息的默认保留时间为24小时。 最小值为 1 小时，最大值为 30 天。

有关创建主题时可修改的设置的指导，请参阅 主题配置。

预期的 HTTP 状态代码如下：

• 202: 已接受主题创建请求。
• 400: 请求 JSON 无效。
• 403: 无权创建主题。
• 422: 请求在语义上无效。

如果创建 Kafka 主题的请求成功，则返回 HTTP 状态代码202（已接受）。 如果操作失败，将返回状态代码 HTTP 422（无法处理的实体），并返回一个JSON对象作为响应主体，其中包含有关失败的附加信息。

curl -i -X POST -H 'Accept: application/json' -H 'Content-Type: application/json' -H 'Authorization: Bearer ${TOKEN}' --data '{ "name": "newtopic", "partitions": 1}' ${ADMIN_URL}/admin/topics

[
  {
    "name": "topic1",
    "partitions": 1,
    "retentionMs": 86400000,
    "cleanupPolicy": "delete"
  },
  { "name": "topic2",
    "partitions": 2,
    "retentionMs": 86400000,
    "cleanupPolicy": "delete"
  }
]

curl -i -X GET -H 'Accept: application/json' -H 'Authorization: Bearer ${TOKEN}' ${ADMIN_URL}/admin/topics

步骤 4: 使用控制台创建服务凭证

要允许您连接到 Event Streams 实例，请使用 IBM Cloud 控制台创建服务密钥:

1. 在 资源列表中找到 Event Streams 服务。
2. 单击服务磁贴。
3. 单击服务凭证。
4. 单击新建凭证。
5. 填写新凭证的详细信息，例如名称和角色，并单击添加。 凭证列表中将显示新的凭证。
6. 展开新凭证的部分以显示 JSON 格式的详细信息。

步骤 4: 使用 CLI 创建服务凭证

使用 IBM Cloud CLI 创建服务密钥，以便您可以连接到 Event Streams 实例:

1. 找到您的服务：

   ibmcloud resource service-instances
   

2. 创建服务密钥：

   ibmcloud resource service-key-create <key_name> <key_role> --instance-name <your_service_name>
   

3. 打印服务密钥：

   ibmcloud resource service-key <key_name>
   

   每个服务密钥中都包含一组端点详细信息。 对于配置为连接到单个网络类型 ( IBM Cloud 公用网络 (缺省值) 或 IBM Cloud 专用网络) 的服务实例，服务密钥包含与该网络类型相关的详细信息。 对于配置为同时支持专用网络和公用网络的实例，将返回公用网络的详细信息。 如果需要专用网络的详细信息，那么必须将 --service-endpoint private 参数添加到先前的 service-key-create CLI 命令。 例如：

   ibmcloud resource service-key-create <private-key-name> <role> --instance-name <instance-name> --service-endpoint private
   

步骤 4: 使用 CLI 和 REST 生产者 API 创建服务凭证

要连接到 Event Streams 实例，受支持的认证机制正在使用不记名令牌。 要使用 IBM Cloud CLI 获取令牌，请首先登录到 IBM Cloud，然后运行以下命令:

ibmcloud iam oauth-tokens

请将此令牌放入 Bearer<token> 表单中 HTTP 请求的授权标题中。 支持 API 密钥或 JWT 令牌。

步骤 5: 使用控制台生成数据

无法使用控制台生成数据。 您可以使用 命令行，REST 生产者 API 或 Kafka API 来生成数据。

但是，您可以在 入门教程 中完成控制台的步骤，以运行样本入门模板应用程序并查看流经主题的消息。

步骤 5: 使用命令行生成数据

您可以使用 Event Streams Kafka 控制台生产者工具来生成数据。 控制台工具位于 Kafka 客户机下载的 bin 目录中，您可以从 Apache Kafka 下载下载该目录。 建议您下载最新的可用稳定二进制版本。 Kafka 客户机版本与服务器上的 Kafka 版本向后兼容。

必须提供代理 (使用 BOOTSTRAP_ENDPOINTS 属性) 和 SASL 凭证的列表。

要向该工具提供SASL凭证，请根据以下示例创建一个属性文件：

    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<user>" password="<api_key>";
    security.protocol=SASL_SSL
    sasl.mechanism=PLAIN
    ssl.protocol=TLSv1.2
    ssl.enabled.protocols=TLSv1.2
    ssl.endpoint.identification.algorithm=HTTPS

使用服务密钥中的 <user> 字段作为用户名，使用服务密钥中的 <api_key> 字段作为密码。 您可以在 IBM Cloud 控制台的 Event Streams 服务凭证 选项卡中找到这些值。

Event Streams 提供了 Java 客户机 的示例 producer.properties 和 consumer.properties 文件。

创建属性文件后，您可以在终端中运行控制台生成器，如下所示：

   kafka-console-producer.sh --broker-list BOOTSTRAP_ENDPOINTS --producer.config CONFIG_FILE --topic TOPIC_NAME

将示例中的以下变量替换为您自己的值：

• 具有来自 IBM Cloud 控制台中 Event Streams 服务凭证 选项卡的值的 BOOTSTRAP_ENDPOINTS。
• 将 CONFIG_FILE 替换为配置文件的路径。

• 使用服务密钥中的 <bootstrap_endpoints> 字段作为 Kafka 应用程序的 bootstrap.servers 属性。
• 使用服务密钥中的 <user> 字段作为用户名，使用服务密钥中的 <api_key> 字段作为密码。 确保您的应用程序会解析这些详细信息。

您可以使用该工具的许多其他选项，但需要访问 ZooKeeper 的选项除外。 有关更多信息，请参阅 将 Kafka 控制台工具与 Event Streams配合使用。

步骤 5: 使用 REST Producer API 生成数据

使用 REST 生产者 API 的 v2 端点将类型为 text，binary，JSON 或 avro 的消息发送到主题。 通过 v2 端点，您可以通过指定 avro 数据类型的模式来使用 Event Streams 模式注册表。

• 什么是头? 它们是可选的吗? 您将在消息体中看到头。 这是包含请求或响应中的所有内容的数据块。 头通常在请求行或响应行之后。 颜色值为 base64-如何执行此操作?

以下代码展示了使用curl发送 text 类型消息的示例：

curl -v -X POST \
-H "Authorization: Bearer $token" -H "Content-Type: application/json" -H "Accept: application/json" \
-d '{
  "headers": [
    {
      "name": "colour",
      "value": "YmxhY2s="
    }
  ],
  "key": {
    "type": "text",
    "data": "Test Key"
  },
  "value": {
    "type": "text",
    "data": "Test Value"
  }
}' \
"$kafka_http_url/v2/topics/$topic_name/records"

有关更多信息，请参阅 Event Streams REST Producer v2 端点 API 参考。

步骤 6: 使用控制台来使用数据

不能使用控制台来使用数据。 您可以使用 命令行 或 Kafka API 来使用数据。

但是，您可以完成 入门教程 中的步骤，以运行样本入门模板应用程序并查看流经主题的消息。

步骤 6: 使用命令行来使用数据

您可以使用 Event Streams Kafka 控制台使用者工具来使用数据。

控制台工具位于 Kafka 客户机下载的 bin 目录中。

您必须提供代理程序和 SASL 凭证的列表。 创建属性文件后，如 使用命令行生成数据 中所述，在终端中运行控制台使用者，如下所示:

   kafka-console-consumer.sh --bootstrap-server BOOTSTRAP_ENDPOINTS --consumer.config CONFIG_FILE --topic TOPIC_NAME

将示例中的以下变量替换为您自己的值：

• 具有来自 IBM Cloud 控制台中 Event Streams 服务凭证 选项卡的值的 BOOTSTRAP_ENDPOINTS。
• 将 CONFIG_FILE 替换为配置文件的路径。

您可以使用该工具的许多其他选项，但需要访问 ZooKeeper 的选项除外。 有关更多信息，请参阅 将 Kafka 控制台工具与 Event Streams配合使用。

步骤 6: 使用 API 来使用数据

无法使用 Event Streams API 来使用数据，尽管可以使用本机 Kafka 库来使用 Kafka 中的数据。 有关更多信息，请参阅 Kafka 使用者 API。

作为替代方法，请使用 命令行。

步骤 7: 使用控制台连接 IBM Cloud Monitoring 以获取操作可视性

您可以使用 IBM Cloud Monitoring 来获取应用程序，服务和平台的性能和运行状况的操作可视性。IBM Cloud Monitoring 为管理员，DevOps 团队和开发者提供了具有高级功能的完整堆栈遥测，用于监视和故障诊断，定义警报以及设计定制仪表板。

有关如何使用 Monitoring 和 Event Streams 的更多信息，请参阅：

• 选择性加入度量
• 启用缺省度量
• 启用增强的度量
• 查看可用度量的详细信息
• 了解度量成本信息

步骤 7: 使用 CLI 或命令行连接 IBM Cloud Monitoring 以获取操作可视性

无法使用 CLI 或命令行连接 IBM Cloud Monitoring。 使用 控制台 来完成此任务。

步骤 7: 使用 API 连接 IBM Cloud Monitoring 以获取操作可视性

无法使用 API 连接 IBM Cloud Monitoring。 使用 控制台 来完成此任务。

步骤 8: 将 IBM Cloud® Activity Tracker 连接到审计服务活动

IBM Cloud Activity Tracker 允许您查看，管理和审计服务活动以符合公司策略和行业法规。Activity Tracker 记录用户启动的活动，这些活动用于更改 IBM Cloud中服务的状态。 使用 Activity Tracker 跟踪用户和应用程序与标准和企业计划中的 Event Streams 服务的交互情况。

要启动并运行 Activity Tracker，请参阅 Activity Tracker入门。

每个位置只能有一个 Activity Tracker 实例。 要查看事件，必须在您的服务实例所在位置访问 Activity Tracker 服务的 Web UI。 有关更多信息，请参阅 启动 Web UI。

有关特定于 Event Streams的事件的更多信息，请参阅:

• 在哪里查看事件
• 主题事件
• 消息审计事件
• 其他事件

活动根据云审计数据联合会（CADF）标准进行格式化。 有关它们包含的信息的更多详细信息，请参阅 CADF 标准。

步骤 8: 使用 CLI 或命令行连接 IBM Cloud® Activity Tracker 以审计服务活动

无法使用 CLI 或命令行连接 Activity Tracker。 使用 控制台 来完成此任务。

步骤 8: 使用 API 审计服务活动来连接 IBM Cloud® Activity Tracker

无法使用 API 连接 Activity Tracker。 使用 控制台 来完成此任务。