Skip to content
This repository has been archived by the owner on Jun 7, 2024. It is now read-only.

Commit

Permalink
Merge pull request #603 from zalando/feaure/aruhe-600
Browse files Browse the repository at this point in the history
aruha-600: api change for reseting subscription cursor
  • Loading branch information
adyach authored Mar 13, 2017
2 parents 0103a87 + f80d614 commit 0a4ddb8
Showing 1 changed file with 43 additions and 0 deletions.
43 changes: 43 additions & 0 deletions api/nakadi-event-bus-api.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -871,6 +871,46 @@ paths:
description: Unprocessable Entity
schema:
$ref: '#/definitions/Problem'
patch:
tags:
- subscription-api
security:
- oauth2: ['nakadi.event_stream.read']
description: |
Endpoint for resetting subscription offsets.
The subscription consumers will be disconnected during offset reset. The request can hang up until
subscription commit timeout. During that time requests to subscription streaming endpoint
will be rejected with 409. The clients should reconnect once the request is finished with 204.
parameters:
- name: subscription_id
in: path
type: string
description: Id of subscription
required: true
- name: cursors
in: body
schema:
type: object
properties:
items:
description: |
List of cursors to reset subscription to.
type: array
items:
$ref: '#/definitions/SubscriptionCursorWithoutToken'
required:
- items
responses:
'204':
description: Offsets were reset
'404':
description: Subscription not found
schema:
$ref: '#/definitions/Problem'
'422':
description: Unprocessable Entity
schema:
$ref: '#/definitions/Problem'

/subscriptions/{subscription_id}/events:
get:
Expand Down Expand Up @@ -933,6 +973,9 @@ paths:
description: |
Conflict. There are no empty slots for this subscriptions. The amount of consumers for this subscription
already equals the maximal value - the total amount of this subscription partitions.
This status code is also returned in the case of resetting subscription cursors request still in the
progress.
schema:
$ref: '#/definitions/Problem'
'403':
Expand Down

0 comments on commit 0a4ddb8

Please sign in to comment.