Stream Receive
Receives messages from a topic using a consumer group.
Each consumer in the group reads from all partitions. Messages are locked by leases for the specified duration to prevent duplicate delivery within the same consumer group.
Request body
Example request
{
"namespace": "some_namespace",
"topic": "some_topic_name",
"consumer_group": "some_consumer_group"
}Response
Example response
{
"msgs": [
{
"topic": "some_topic_name~0"
}
]
}Changes
Changed in 9 of the 53 revisions of this API.141926
- ●
added the new
invalid-inputenum value to thetyperesponse property for the response status400response-property-enum-value-added
- ●
added the new
invalid-inputenum value to thetyperesponse property for the response status401response-property-enum-value-added
- ●
added the new
invalid-inputenum value to thetyperesponse property for the response status403response-property-enum-value-added
- ●
added the new
invalid-inputenum value to thetyperesponse property for the response status422response-property-enum-value-added
- ●
added the new
operation-errorenum value to thetyperesponse property for the response status400response-property-enum-value-added
- ●
added the new
operation-errorenum value to thetyperesponse property for the response status401response-property-enum-value-added
- ●
added the new
operation-errorenum value to thetyperesponse property for the response status403response-property-enum-value-added
- ●
added the new
operation-errorenum value to thetyperesponse property for the response status422response-property-enum-value-added
- ●
added the new
server-errorenum value to thetyperesponse property for the response status400response-property-enum-value-added
- ●
added the new
server-errorenum value to thetyperesponse property for the response status401response-property-enum-value-added
- ●
added the new
server-errorenum value to thetyperesponse property for the response status403response-property-enum-value-added
- ●
added the new
server-errorenum value to thetyperesponse property for the response status422response-property-enum-value-added
- ○
removed the
invalid_inputenum value from thetyperesponse property for the response status400response-property-enum-value-removed
- ○
removed the
invalid_inputenum value from thetyperesponse property for the response status401response-property-enum-value-removed
- ○
removed the
invalid_inputenum value from thetyperesponse property for the response status403response-property-enum-value-removed
- ○
removed the
invalid_inputenum value from thetyperesponse property for the response status422response-property-enum-value-removed
- ○
removed the
operation_errorenum value from thetyperesponse property for the response status400response-property-enum-value-removed
- ○
removed the
operation_errorenum value from thetyperesponse property for the response status401response-property-enum-value-removed
- ○
removed the
operation_errorenum value from thetyperesponse property for the response status403response-property-enum-value-removed
- ○
removed the
operation_errorenum value from thetyperesponse property for the response status422response-property-enum-value-removed
- ○
removed the
server_errorenum value from thetyperesponse property for the response status400response-property-enum-value-removed
- ○
removed the
server_errorenum value from thetyperesponse property for the response status401response-property-enum-value-removed
- ○
removed the
server_errorenum value from thetyperesponse property for the response status403response-property-enum-value-removed
- ○
removed the
server_errorenum value from thetyperesponse property for the response status422response-property-enum-value-removed
- ●
- ○
added the required property
typeto the response with the400statusresponse-required-property-added
- ○
added the required property
typeto the response with the401statusresponse-required-property-added
- ○
added the required property
typeto the response with the403statusresponse-required-property-added
- ○
added the required property
typeto the response with the422statusresponse-required-property-added
This revision also has 1 change that name no endpoint, such as unreferenced schemas being removed. See the revision's changelog
- ○
- ▲
the
detailresponse's property type/format changed fromarray/tostring/for status422response-property-type-changed
- ○
added the optional property
locationto the response with the400statusresponse-optional-property-added
- ○
added the optional property
locationto the response with the401statusresponse-optional-property-added
- ○
added the optional property
locationto the response with the403statusresponse-optional-property-added
- ○
added the optional property
locationto the response with the422statusresponse-optional-property-added
- ○
added the required property
codeto the response with the422statusresponse-required-property-added
This revision also has 2 changes that name no endpoint, such as unreferenced schemas being removed. See the revision's changelog
- ▲
- ▲
the
namespacerequest property's minLength was increased from0to1request-property-min-length-increased
- ▲
- ▲
added the pattern
^[a-zA-Z0-9\-/_.=+]+$to the request propertynamespacerequest-property-pattern-added
- ●
the
namespacerequest property's maxLength was set to256request-property-max-length-set
- ▲
- ▲
the
msgs/items/scheduled_atresponse's property type/format changed fromstring/date-timetointeger/uint64for status200response-property-type-changed
- ▲
the
msgs/items/timestampresponse's property type/format changed fromstring/date-timetointeger/uint64for status200response-property-type-changed
- ▲
- ○
the response property
msgs/items/headersbecame required for the status200response-property-became-required
- ○
the
headersresponse's property default value{}was removed for the status200response-property-default-value-removed
- ○
- ●
the
batch_wait_msrequest property's min was set to0.00request-property-min-set
- ●
the
lease_duration_msrequest property's min was set to0.00request-property-min-set
- ●
- ▲
the response property
msgs/items/headersbecame optional for the status200response-property-became-optional
- ▲
the
detailresponse's property type/format changed fromstring/toarray/for status422response-property-type-changed
- ▲
the
msgs/items/scheduled_atresponse's property type/format changed frominteger/uint64tostring/date-timefor status200response-property-type-changed
- ▲
the
msgs/items/timestampresponse's property type/format changed frominteger/uint64tostring/date-timefor status200response-property-type-changed
- ▲
removed the required property
codefrom the response with the422statusresponse-required-property-removed
- ▲
removed the required property
typefrom the response with the400statusresponse-required-property-removed
- ▲
removed the required property
typefrom the response with the401statusresponse-required-property-removed
- ▲
removed the required property
typefrom the response with the403statusresponse-required-property-removed
- ▲
removed the required property
typefrom the response with the422statusresponse-required-property-removed
- ●
removed the optional property
locationfrom the response with the400statusresponse-optional-property-removed
- ●
removed the optional property
locationfrom the response with the401statusresponse-optional-property-removed
- ●
removed the optional property
locationfrom the response with the403statusresponse-optional-property-removed
- ●
removed the optional property
locationfrom the response with the422statusresponse-optional-property-removed
- ○
the
namespacerequest property's minLength was decreased from1to0request-property-min-length-decreased
- ○
removed the pattern
^[a-zA-Z0-9\-/_.=+]+$from the request propertynamespacerequest-property-pattern-removed
- ○
the
headersresponse's property default value{}was added for the status200response-property-default-value-added
This revision also has 35 changes that name no endpoint, such as unreferenced schemas being removed. See the revision's changelog
- ▲