如何解决如何在 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
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。