安装基本群集

要启动基本测试群集 有三个 broker,在 DC/OS CLI 上运行以下命令。

$ dcos package install kafka

此命令将创建具有默认名称 kafka 的新实例。两个实例不能使用相同的名称,因此在默认实例之外,安装其他实例时需要在每次安装时自定义 name

所有 dcos kafka CLI 命令具有一个 --name 自变量,其允许您指定要查询的实例。如果未指定服务名称,CLI 将假设与包名称匹配的默认值,kafka--name 的默认值可通过 DC/OS CLI 配置进行自定义:

$ dcos kafka --name=kafka <cmd>

或者,您可以 从 DC/OS Web 界面安装。如果您从 DC/OS Web 界面安装 Apache Kafka,dcos kafka CLI 命令不会自动安装到工作站中。可以使用 DC/OS CLI 手动安装它们:

dcos package install kafka --cli

运行 package install 命令后,服务将开始安装。

Enterprise DC/OS 安装

根据 Enterprise DC/OS 群集的 安全模式,Enterprise DC/OS 用户可能需要创建自定义 .json 文件并使用它来安装 Apache Kafka。

创建配置文件

创建将用于安装 Apache Kafka 的自定义配置文件,并将其保存为 config.json。指定服务帐户 (<service_account_id>) 和秘密的道路 (kafka/<secret-name>) .

{
  "service": {
    "service_account": "<service_account_id>",
    "service_account_secret": "kafka/<secret-name>"
  }
}

使用自定义配置文件进行安装

通过此命令使用刚创建的自定义配置文件安装 Apache Kafka :

dcos package install --options=config.json kafka

服务部署

要监控测试实例的部署,安装包 cli(请参阅上面的命令)并运行命令:

dcos kafka plan show deploy

部署计划的状态为 Complete时,即表示服务已完全部署。

服务发现

要连接客户端,请通过服务查询其端点。

dcos kafka endpoints

从列表中选择一个端点以查看可用连接。

dcos kafka endpoints <endpoint>

使用服务

使用端点信息,您可以从/在 DC/OS 群集中将客户端连接到服务(例如,运行客户端应用程序的 Marathon 应用)。有关配置、操作和服务功能的更多详细信息,请参阅文档的其他部分。