故障排除

配置更新错误

配置更改后，服务可能会进入不健康状态。这通常在用户进行无效配置更改时发生。某些配置值可能不会被更改，或可能不会被减少。要验证是否如此，对于任何错误，请检查服务的 deploy 计划。

$ dcos kafka --name=<service-name> plan show deploy

访问日志

调度程序和所有服务节点的日志可从 DC/OS Web 界面查看。

调度程序日志对于确定节点未启动的原因会有帮助（这位于调度程序视界下）。
节点日志对于检查服务本身的问题有帮助。

在所有情况下，日志通常被管道传递到名为 stdout 和/或 stderr文件中。

要查看给定节点的日志，执行以下步骤：

访问<dcos-url> 以进入 DC/OS Web 界面。
导航至 Services 并单击要检查的服务。
在服务的任务列表中，单击要检查的任务（调度程序依据服务命名，节点则根据其类型命名为 node-<#>-server）。
在任务详细信息中，单击 Logs 选项卡进入日志查看器。默认情况下，您将查看 stdout，但 stderr 也很有用。使用右上方的下拉菜单选择要检查的文件。

您也可通过 Mesos UI 访问日志：

访问<dcos-url>/mesos 查看 Mesos UI。
单击左上方的 Frameworks 选项卡，以获取群集中运行的服务列表。
按需要导航至正确的框架。调度程序在 marathon 下运行，并有与服务名称匹配的任务名称（默认 kafka）。服务节点在名称与服务名称匹配的框架下运行（默认 kafka）。
您现在应该看到两个任务列表。Active Tasks 是当前正在运行的任务，Completed Tasks 是已退出的任务。单击您要检查的任务的 Sandbox 链接。
Sandbox 视图将列出名为 stdout 和 stderr的文件。单击文件名以在浏览器中查看文件，或单击 Download 将其下载到您的系统进行本地检查。请注意，很旧的任务将自动删除其沙盒，以限制磁盘空间的使用。

替换永久故障节点

DC/OS Apache Kafka 服务对临时 Pod 故障有复原能力，如果其停止运行，则会自动重新启动它们。然而，如果托管 Pod 的机器永久丢失，需要手动干预来丢弃停工的 Pod，并在新机器上重建它。

应使用以下命令获取可用 Pod 的列表。

$ dcos kafka --name=<service-name> pod list

然后应借助上述列表中提供的适当的 pod_name，使用以下命令更换故障机器上的 Pod。

$ dcos kafka --name=<service-name> pod replace <pod_name>

Pod 然后可通过 recovery 计划恢复。

$ dcos kafka --name=<service-name> plan show recovery

重新启动节点

如果您必须强制重新启动 Pod 的进程，但不想清除该 Pod 的数据，使用以下命令在其当前所在的同一代理机器上重新启动该 Pod。这不会导致中断或数据丢失。

应使用以下命令获取可用 Pod 的列表。

$ dcos kafka --name=<service-name> pod list

然后应使用以下命令重启 Pod，使用在上述列表中提供的相应的命令 pod_name 。

$ dcos kafka --name=<service-name> pod restart <pod_name>

Pod 然后可通过 recovery 计划恢复。

$ dcos kafka --name=<service-name> plan show recovery

任务未部署/资源匮乏

当调度程序尝试启动任务时，它将记录有关于其已收到资源的决定。在确定任务未能部署的原因时，这很有用。

最近的服务版本中，调度程序端点位于http://yourcluster.com/service/<service-name>/v1/debug/offer 将显示一个HTML表，其中包含最近评估的商品摘要. 此表的内容目前与日志中的内容非常相似，但格式更易于访问. 另外, 我们可以查看调度程序的日志 stdout。

以下示例假设一个需要预先确定资源数量的假定任务。滚动调度程序日志，我们看到了几个模式。首先，存在这样的故障，其中缺少唯一的东西是 CPU。剩余的任务需要两个 CPU，但此资源供应显然不够：

INFO  2017-04-25 19:17:13,846 [pool-8-thread-1] com.mesosphere.sdk.offer.evaluate.OfferEvaluator:evaluate(69): Offer 1: failed 1 of 14 evaluation stages:
  PASS(PlacementRuleEvaluationStage): No placement rule defined
  PASS(ExecutorEvaluationStage): Offer contains the matching Executor ID
  PASS(ResourceEvaluationStage): Offer contains sufficient 'cpus': requirement=type: SCALAR scalar { value: 0.5 }
  PASS(ResourceEvaluationStage): Offer contains sufficient 'mem': requirement=type: SCALAR scalar { value: 500.0 }
  PASS(LaunchEvaluationStage): Added launch information to offer requirement
  FAIL(ResourceEvaluationStage): Failed to satisfy required resource 'cpus': name: "cpus" type: SCALAR scalar { value: 2.0 } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
  PASS(ResourceEvaluationStage): Offer contains sufficient 'mem': requirement=type: SCALAR scalar { value: 8000.0 }
  PASS(MultiEvaluationStage): All child stages passed
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 9042 end: 9042 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 9160 end: 9160 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 7000 end: 7000 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 7001 end: 7001 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 8609 end: 8609 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 8182 end: 8182 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 7199 end: 7199 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 21621 end: 21621 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 8983 end: 8983 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 7077 end: 7077 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 7080 end: 7080 } }
    PASS(PortEvaluationStage): Offer contains sufficient 'ports': requirement=type: RANGES ranges { range { begin: 7081 end: 7081 } }
  PASS(VolumeEvaluationStage): Offer contains sufficient 'disk'
  PASS(VolumeEvaluationStage): Offer contains sufficient 'disk'
  PASS(VolumeEvaluationStage): Offer contains sufficient 'disk'
  PASS(VolumeEvaluationStage): Offer contains sufficient 'disk'
  PASS(LaunchEvaluationStage): Added launch information to offer requirement
  PASS(ReservationEvaluationStage): Added reservation information to offer requirement

如果我们从此拒绝摘要中向上滚动，我们发现一条描述代理提供 CPU 相关资源的消息：

INFO  2017-04-25 19:17:13,834 [pool-8-thread-1] com.mesosphere.sdk.offer.MesosResourcePool:consumeUnreservedMerged(239): Offered quantity of cpus is insufficient: desired type: SCALAR scalar { value: 2.0 }, offered type: SCALAR scalar { value: 0.5 }

可以理解，当节点需要 2.0 CPU 而系统只剩 0.5 CPU 时，我们的调度程序拒绝在系统上启动节点。

我们看到的另一种模式是出于如下若干原因，所提供的资源被拒绝：

INFO  2017-04-25 19:17:14,849 [pool-8-thread-1] com.mesosphere.sdk.offer.evaluate.OfferEvaluator:evaluate(69): Offer 1: failed 6 of 14 evaluation stages:
  PASS(PlacementRuleEvaluationStage): No placement rule defined
  PASS(ExecutorEvaluationStage): Offer contains the matching Executor ID
  FAIL(ResourceEvaluationStage): Failed to satisfy required resource 'cpus': name: "cpus" type: SCALAR scalar { value: 0.5 } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
  PASS(ResourceEvaluationStage): Offer contains sufficient 'mem': requirement=type: SCALAR scalar { value: 500.0 }
  PASS(LaunchEvaluationStage): Added launch information to offer requirement
  FAIL(ResourceEvaluationStage): Failed to satisfy required resource 'cpus': name: "cpus" type: SCALAR scalar { value: 2.0 } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } } FAIL(ResourceEvaluationStage): Failed to satisfy required resource 'mem': name: "mem" type: SCALAR scalar { value: 8000.0 } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
  FAIL(MultiEvaluationStage): Failed to pass all child stages
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 9042 end: 9042 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 9160 end: 9160 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 7000 end: 7000 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 7001 end: 7001 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 8609 end: 8609 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 8182 end: 8182 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 7199 end: 7199 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 21621 end: 21621 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 8983 end: 8983 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 7077 end: 7077 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 7080 end: 7080 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
    FAIL(PortEvaluationStage): Failed to satisfy required resource 'ports': name: "ports" type: RANGES ranges { range { begin: 7081 end: 7081 } } role: "kafka-role" reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
  FAIL(VolumeEvaluationStage): Failed to satisfy required volume 'disk': name: "disk" type: SCALAR scalar { value: 10240.0 } role: "kafka-role" disk { persistence { id: "" principal: "kafka-principal" } volume { container_path: "kafka-data" mode: RW } } reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
  PASS(VolumeEvaluationStage): Offer contains sufficient 'disk'
  PASS(VolumeEvaluationStage): Offer contains sufficient 'disk'
  FAIL(VolumeEvaluationStage): Failed to satisfy required volume 'disk': name: "disk" type: SCALAR scalar { value: 10240.0 } role: "kafka-role" disk { persistence { id: "" principal: "kafka-principal" } volume { container_path: "solr-data" mode: RW } } reservation { principal: "kafka-principal" labels { labels { key: "resource_id" value: "" } } }
  PASS(LaunchEvaluationStage): Added launch information to offer requirement
  PASS(ReservationEvaluationStage): Added reservation information to offer requirement

在这种情况下，我们发现在此系统上没有我们的任务需要的可用端口（更不用提缺少足够的 CPU 和 RAM）。当我们查看已经对其进行部署的代理时，通常会发生这种情况。此处的代理可能会为此服务运行一个现有节点，而其中我们已经将那些端口保留给自己了。

我们看到，集群中的剩余代理无一有余度适配我们的第三个节点。要解决此问题，我们需要将更多代理添加到 DC/OS 群集，或者我们需要降低服务的要求以使其适配。在后一种情况中，要了解如果资源使用量减少太多而可能导致的任何性能问题。CPU 配额不足会导致任务受限制，不足 RAM 配额将导致任务内存不足。

这是您可以通过撇开调度程序日志来执行的诊断类型的很好示例。

意外删除 Marathon 任务，而非服务

常见用户错误是从 Marathon 中删除调度程序任务，这不会自行卸载服务任务自身。如果您这样做，您有两个选择：

卸载其余服务

如果您真的想卸载服务，您只需要完成卸载下所述的正常 package uninstall 步骤。

恢复调度程序

如果您想让调度程序恢复，您可以运行 dcos package install 进程，使用您之前配置的选项。这将重新安装一个与前一个调度程序匹配的新的调度程序（假设您正确选择了您的选项），其将在上次离开的地方重新开始。为确保您不忘记配置服务的选项，我们建议在源控件中保留一份服务的 options.json 副本，以便后面轻松恢复。

“框架已删除”

该服务之前安装过同名的实例，且未正确卸载。有关完成不完全卸载的步骤，请参阅卸载。

内存不足 (OOMed) 任务

如果您没有对其提供足够的资源，您的任务可能会因为 OOM（内存不足错误）而被终止。这会通过日志任务中的意外的 Killed 消息而显示，有时持续这样，但通常不是。要验证原因是否为 OOM 错误，可以检查以下位置：

检查调度程序日志（或 dcos <svcname> pod status <podname>） 以查看给定出故障的 Pod 中的“TaskStatus”更新。
直接检查代理日志，看看是否有提及由于超过内存使用量 Mesos 代理节点杀死任务的消息。

在您确认问题确实是 OOM 错误之后，您也可以通过更新服务配置来保留更多内存加以解决。

分区复制

在检测到任何复制不足的分区时，Kafka 可能会变得不健康。此错误状况通常表示 broker 已出故障。使用 dcos kafka --name=kafka topic under_replicated_partitions 和 dcos kafka --name=kafka topic describe <topic-name> 命令来查找问题 broker 并确定需要哪些操作。

可能的修复操作包括重新启动受影响的 broker 和破坏性替换受影响的 broker。replace 操作具有破坏性，将会不可撤销地丢失与 broker 有关的所有数据。 restart 操作没有破坏性，并表示尝试重新启动 broker 进程。

Broker 关闭

如果 Kafka broker 无法在所配置的 brokers.kill_grace_period（终止宽限期）内完全关闭，则延长终止宽限期。

诊断 Kafka