Kafka Consumer Groups
Delete the offset for a consumer group topic-partition tuples
The consumer group id
No content
The request input was invalid
Authentication error
The purchased Lenses license does not provide access to this feature
Authorisation error
The requested resource cannot be found
An internal server error has occurred
POST /api/v1/environments/{name}/proxy/api/consumers/{groupId}/offsets/delete HTTP/1.1
Host:
Content-Type: application/json
Accept: */*
Content-Length: 19
{
"topics": [
"text"
]
}
No content
Delete the offset for a topic-partition for the given group
The consumer group id
The topic name
The topic partition number
No content
The request input was invalid
Authentication error
The purchased Lenses license does not provide access to this feature
Authorisation error
The requested resource cannot be found
An internal server error has occurred
DELETE /api/v1/environments/{name}/proxy/api/consumers/{groupId}/topics/{topic}/partitions/{partition}/offsets HTTP/1.1
Host:
Accept: */*
No content
Returns the consumer groups which are using the given topic
The consumer group name
No content
The request input was invalid
Authentication error
The purchased Lenses license does not provide access to this feature
Authorisation error
The requested resource cannot be found
An internal server error has occurred
DELETE /api/v1/environments/{name}/proxy/api/consumers/{consumerGroupName} HTTP/1.1
Host:
Accept: */*
No content
Update the offset for a consumer group topic-partition tuples
The consumer group id
No content
The request input was invalid
Authentication error
The purchased Lenses license does not provide access to this feature
Authorisation error
The requested resource cannot be found
An internal server error has occurred
PUT /api/v1/environments/{name}/proxy/api/consumers/{groupId}/offsets HTTP/1.1
Host:
Content-Type: application/json
Accept: */*
Content-Length: 19
{
"topics": [
"text"
]
}
No content
Updates the offset for a topic-partition for the given group
The consumer group id
The topic name
The topic partition number
No content
The request input was invalid
Authentication error
The purchased Lenses license does not provide access to this feature
Authorisation error
The requested resource cannot be found
An internal server error has occurred
PUT /api/v1/environments/{name}/proxy/api/consumers/{groupId}/offsets/topics/{topic}/partitions/{partition} HTTP/1.1
Host:
Content-Type: application/json
Accept: */*
Content-Length: 12
{
"offset": 1
}
No content
Returns the consumer groups which are using the given topic
The topic name
The request input was invalid
Authentication error
The purchased Lenses license does not provide access to this feature
Authorisation error
The requested resource cannot be found
An internal server error has occurred
GET /api/v1/environments/{name}/proxy/api/consumers/{topic} HTTP/1.1
Host:
Accept: */*
[
{
"id": "text",
"coordinator": {
"id": 1,
"host": "text",
"port": 1,
"rack": "text"
},
"active": true,
"state": "Unknown",
"consumers": [
{
"topic": "text",
"partition": 1,
"currentOffset": 1,
"startOffset": 1,
"logEndOffset": 1,
"lag": 1,
"consumerId": "text",
"host": "text",
"clientId": "text"
}
],
"application": {
"id": "text",
"name": "text",
"type": "AkkaStreams"
}
}
]
Returns the list of Kafka consumer groups
The request input was invalid
Authentication error
The purchased Lenses license does not provide access to this feature
Authorisation error
The requested resource cannot be found
An internal server error has occurred
GET /api/v1/environments/{name}/proxy/api/consumers HTTP/1.1
Host:
Accept: */*
[
{
"id": "text",
"coordinator": {
"id": 1,
"host": "text",
"port": 1,
"rack": "text"
},
"active": true,
"state": "Unknown",
"consumers": [
"text"
],
"consumersCount": 1,
"topicPartitionsCount": 1,
"minLag": 1,
"maxLag": 1,
"application": {
"id": "text",
"name": "text",
"type": "AkkaStreams"
}
}
]
Last updated
Was this helpful?