如何在 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 方法如何放置主体，或者还有其他方法吗？

解决方法

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

apache-kafka get