Consumer Groups
Return a list of consumers that belong to the specified consumer group.
Lists all active consumers that are members of the specified consumer group. Includes consumer metadata such as client ID, host, and partition assignments.
GET
/
admin
/
v1
/
consumer-groups
/
{consumer_group_id}
/
consumers
Return a list of consumers that belong to the specified consumer group.
curl --request GET \
--url https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumersimport requests
url = "https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_body{
"data": [
{
"consumer_group_id": "<string>",
"consumer_id": "<string>",
"client_id": "<string>",
"host": "<string>",
"metadata": {},
"kind": "<string>"
}
],
"metadata": {},
"kind": "<string>"
}Was this page helpful?
Return the list of consumer groups.
Previous
Return the consumer group specified by the consumer_group_id.
Next
⌘I
Return a list of consumers that belong to the specified consumer group.
curl --request GET \
--url https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumersimport requests
url = "https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/admin/v1/consumer-groups/{consumer_group_id}/consumers")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_body{
"data": [
{
"consumer_group_id": "<string>",
"consumer_id": "<string>",
"client_id": "<string>",
"host": "<string>",
"metadata": {},
"kind": "<string>"
}
],
"metadata": {},
"kind": "<string>"
}