时间戳

首页 > 解决方案 > 如何在 Kafka 休息代理中获取分区偏移量

apache-kafka - 如何在 Kafka 休息代理中获取分区偏移量

问题描述

Kafka rest Api 示例请求如下：

GET /consumers/testgroup/instances/my_consumer/offsets HTTP/1.1
Host: proxy-instance.kafkaproxy.example.com
Content-Type: application/vnd.kafka.v2+json, application/vnd.kafka+json, application/json
{
  "partitions": [
    {
      "topic": "test",
      "partition": 0
    },
    {
      "topic": "test",
      "partition": 1
    }
  ]
}

如何请求此 API。对我来说，难题是 get 方法如何放置一个主体，或者还有其他方法吗？

标签： apache-kafkaget

解决方案

cURL 允许这样做：

curl -v 'http://kafka-rest:8082/consumers/myGroup/instances/myInstance/offsets' \
  -X GET \
  -H 'Content-Type: application/vnd.kafka.v2+json' \
  -d '{"partitions": [{"topic": "myTopic", "partition": 0}, {"topic": "myTopic", "partition": 1}]}'

注意：你应该只使用 'application/vnd.kafka.v2+json' 内容类型，否则你会得到 400 Bad Request

推荐阅读