小编Bab*_*hou的帖子

我们有一个由4个节点组成的集群.我们观察到其中一个节点遇到了不断缩小和扩展ISR超过1小时的情况,并且在代理被弹回之前无法恢复.

[2017-02-21 14:52:16,518] INFO Partition [skynet-large-stage,5] on broker 0: Shrinking ISR for partition [skynet-large-stage,5] from 2,0 to 0 (kafka.cluster.Partition)
[2017-02-21 14:52:16,543] INFO Partition [skynet-large-stage,37] on broker 0: Shrinking ISR for partition [skynet-large-stage,37] from 1,0 to 0 (kafka.cluster.Partition)
[2017-02-21 14:52:16,544] INFO Partition [skynet-large-stage,13] on broker 0: Shrinking ISR for partition [skynet-large-stage,13] from 1,0 to 0 (kafka.cluster.Partition)
[2017-02-21 14:52:16,545] INFO Partition [__consumer_offsets,46] on broker 0: Shrinking ISR for partition [__consumer_offsets,46] from 3,2,0 to 3,0 (kafka.cluster.Partition)
.
.

我想知道导致这个问题的原因以及为什么破碎的经纪人没有被赶出ISR.

Kafka版本是0.10.1.0

我使用zkCli.sh列出kafka的路径zookeeper。

通过Kafka+data+structures+in+Zookeeper文档，我发现文档中的所有路径都可以匹配文档，consumers路径除外。

命令ls /consumers，响应[]，但是yahoo 的 kafka manager可以获取消费者信息，例如LogSize，Consumer Offset等等。

我创建了一个 Web 应用程序spring boot。但我发现响应状态代码是200

代替 200 ok

.

我使用return new ResponseEntity<>("xx",HttpStatus.OK);，响应代码也是200。

我有一个存储插入时间的字段，例如2016-10-10 11:00:00.000，我尝试了keywordtype 和datetype，它们都满足range要求，例如

{
    "query": {
        "range" : {
            "time" : {
                "gte" : "2016-10-10 11:00:00.000",
                "lte" : "2016-10-10 12:00:00.000"
            }
        }
    }
}

keyword并date输入哪个更好？