Elasticsearch сумма по сумме от макс - PullRequest
0 голосов
/ 06 декабря 2018

Мне нужна помощь в поиске общего количества сообщений по всем темам.

В приведенном ниже документе содержится более миллиона тем, разделов и смещений.

Мне нужно получить общее количество смещений:

"kafka": {
  "partition": {
    "topic": {
      "name": "testTopic20181206"
    },
    "broker": {
      "id": 4,
      "address": "localhost:9092"
    },
    "partition": {
      "insync_replica": true,
      "id": 0,
      "leader": 3,
      "replica": 1
    },
    "offset": {
      "newest": 17330676,
      "oldest": 0
   }
  }

Я использую следующий запрос:

  GET metricbeat-6*/_search
  {
    "size": 0,
    "aggs": {
      "Topic": {
        "terms": {
          "field": "kafka.partition.topic.name",
          "size": 10000
        },
        "aggregations": {
          "Partition": {
            "terms": {
              "field": "kafka.partition.partition.id"
            },
            "aggregations": {
            "Partition": {
              "max": {
                "field": "kafka.partition.offset.newest"
              }
            }
            }

          }
        }
      }
  }

}

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...