Skip to content
Brokerium

Reset committed offsets of an inactive group

POST
/api/v1/clusters/{id}/groups/{group}/reset-offsets
curl --request POST \
  --url http://localhost:8080/api/v1/clusters/example/groups/example/reset-offsets \
  --header 'Content-Type: application/json' \
  --header 'X-Brokerium-Request: 1' \
  --cookie brokerium_session=<brokerium_session> \
  --data '{ "topic": "example", "partitions": [ 1 ], "to": "earliest", "timestamp": 1, "offset": 1, "dryRun": true }'

Role: operator. Use dryRun to preview the new offsets.

Authorizations

Section titled “Authorizations”

Parameters

Section titled “Parameters”

Path Parameters

Section titled “Path Parameters”
id
required
string
group
required
string

Header Parameters

Section titled “Header Parameters”
X-Brokerium-Request
required
string
Allowed value: 1

Required on every non-GET request.

Request Bodyrequired

Section titled “Request Bodyrequired”
Media typeapplication/json
object
topic
required
string
partitions
Array<integer>
to
required
string
Allowed values: earliest latest timestamp offset
timestamp

Unix milliseconds.

integer format: int64
offset
integer format: int64
dryRun
boolean

Responses

Section titled “Responses”

200

Section titled “200”

Old and new offsets per partition.

Media typeapplication/json
object
dryRun
boolean
offsets
Array<object>
object
topic
string
partition
integer format: int32
from
integer format: int64
to
integer format: int64

Example generated

{
  "dryRun": true,
  "offsets": [
    {
      "topic": "example",
      "partition": 1,
      "from": 1,
      "to": 1
    }
  ]
}

409

Section titled “409”

Error.

Media typeapplication/json
object
error
required
object
code
required
string
message
required
string

Example generated

{
  "error": {
    "code": "example",
    "message": "example"
  }
}

Apache®, Apache Kafka® and Kafka® are either registered trademarks or trademarks of the Apache Software Foundation in the United States and/or other countries. Brokerium is not affiliated with, endorsed by, or sponsored by the Apache Software Foundation.