DC/OS Mesosphere 中的 Kafka CLI

Kafka CLI in DC/OS Mesosphere

我最近开始玩 DC/OS Mesosphere。我在我的集​​群上安装了 Kafka 作为服务。我有一个非常简单的问题:

要列出主题,我还可以使用这个命令吗: kafka-topics --zookeeper zookeeper-host:2181 --list 或者我必须使用 dcos 命令: dcos kafka --name=kafka topic list

谢谢!

如果你愿意,你可以直接运行 kafka-topics,但你需要提供一个与 Kafka 服务实例名称相匹配的 zookeeper 路径(默认 kafka).

您可以通过 运行ning dcos kafka --name=kafka connection 并查看返回数据中的 zookeeper 条目来获取此路径:

$ dcos kafka --name=kafka connection
{
  "address": [
    "10.0.0.58:9603",
    "10.0.0.56:9805",
    "10.0.0.55:9556"
  ],
  "zookeeper": "master.mesos:2181/dcos-service-kafka",
  "dns": [
    "broker-0.kafka.mesos:9603",
    "broker-1.kafka.mesos:9805",
    "broker-2.kafka.mesos:9556"
  ],
  "vip": "broker.kafka.l4lb.thisdcos.directory:9092"
}

在此示例中,传递给 kafka-topics--zookeeper 值应为 master.mesos:2181/dcos-service-kafka。这假定 master.mesos 主机可以从您 运行 宁 kafka-topics 命令的任何地方访问。