安装基本群集
要启动基本测试群集 有三个 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 应用)。有关配置、操作和服务功能的更多详细信息,请参阅文档的其他部分。