Skip to main content

Move a node's position in its queue

POST 

/api/reposition_queue

Sets where a stopped node resumes reading its input topics.

earliest replays everything the broker still retains, latest skips everything queued, and offset moves only the partitions named - the message at that offset is the next one the node processes. Returns 409 if the node is still running, since Kafka refuses an offset change while the consumer group has a member.

Request

Responses

Successful Response