在启动Druid后，当我打开Druid的控制台时使用 http://localhost:8090/console.html 我可以看到所有与Kafka主题相关的主管的名单。然后，当我点击任何一个主管的状态时，我会得到以下json响应
{“id”：“test-kafka7”，“generationtime”：“2017-09-25t12:53:44.003z”，“payload”：{“datasource”：“test-kafka7”，“topic”：“test-kafka2”，“partitions”：1，“replicas”：1，“durationseconds”：3600，“activetasks”：[{“id”：“index\u kafka\u test-kafka7\u 4b18d459ca23552\u dpdodpphp”，“startingoffsets”：{“0”：0}，“starttime”：“2017-09-25t12:44:34.572z”，“remainingseconds”：3050，“type”：“active”，“currentoffsets”：{“0”：0}，“lag”：{“0”：0}]，“publishingtasks”：[]，“latestoffsets”：{“0”：0}，“minimumlag”：{“0”：0}，“aggregatelag”：0，“offsetslastupdated”：“2017-09-25t12:53:31.617z”}
我见过很多次 "remainingSeconds": NNN , "type":"ACTIVE" 在状态中。但我不明白这种类型的含义：活动和剩余秒，剩余秒是为了什么？有时这两个键甚至不出现，所以我太困惑了，为什么它们有时出现，为什么它们不出现，我甚至不明白这些术语的含义。有谁能告诉我这些钥匙是什么意思，为什么它们有时会出现，有时却不出现？
1条答案
按热度按时间kzmpq1sx1#
“主管状态”向您显示它所主管的所有任务的当前状态。“type”和“remainingseconds”字段描述特定的任务。
类型active表示任务当前正在使用来自kafka的数据。另一种可能的类型是发布，这意味着任务是使用来自Kafka的数据完成的，并且已经开始将数据发布到Druid的共享深度存储中。
这就引出了“remainingseconds”，即活动任务转换为发布之前的剩余秒数。每个任务都有一个生命周期，在这个生命周期中，它开始是活动的，然后成为发布的，然后完成。