Msgs

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.

post/api/v1.msgs.stream.receive

Request body

namespacestring nullable
topicstring required
consumer_groupstring required
batch_sizeinteger
lease_duration_msinteger
default_starting_position'earliest' | 'latest'
batch_wait_msinteger nullable

Maximum time (in milliseconds) to wait for messages before returning.

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

  • a542ced3f5931212See the full diff
    • ●

      added the new invalid-input enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new invalid-input enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new invalid-input enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new invalid-input enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new operation-error enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new operation-error enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new operation-error enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new operation-error enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new server-error enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new server-error enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new server-error enum value to the response property for the response status

      response-property-enum-value-added

    • ●

      added the new server-error enum value to the response property for the response status

      response-property-enum-value-added

    • ○

      removed the invalid_input enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the invalid_input enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the invalid_input enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the invalid_input enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the operation_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the operation_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the operation_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the operation_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the server_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the server_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the server_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      removed the server_error enum value from the response property for the response status

      response-property-enum-value-removed

    • ○

      added the required property to the response with the status

      response-required-property-added

    • ○

      added the required property to the response with the status

      response-required-property-added

    • ○

      added the required property to the response with the status

      response-required-property-added

    • ○

      added the required property to the response with the status

      response-required-property-added

    This revision also has 1 change that name no endpoint, such as unreferenced schemas being removed. See the revision's changelog

  • c3022218176815See the full diff
    • ▲

      the response's property type changed from array to string for status

      response-property-type-changed

    • ○

      added the optional property to the response with the status

      response-optional-property-added

    • ○

      added the optional property to the response with the status

      response-optional-property-added

    • ○

      added the optional property to the response with the status

      response-optional-property-added

    • ○

      added the optional property to the response with the status

      response-optional-property-added

    • ○

      added the required property to the response with the status

      response-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 request property's minLength was increased from 0 to 1

      request-property-min-length-increased

  • 14bcce06404b11See the full diff
    • ▲

      added the pattern ^[a-zA-Z0-9\-/_.=+]+$ to the request property

      request-property-pattern-added

    • ●

      the request property's maxLength was set to 256

      request-property-max-length-set

    • ▲

      the // response's property type changed from string to integer, and format from date-time to uint64 for status

      response-property-type-changed

    • ▲

      the // response's property type changed from string to integer, and format from date-time to uint64 for status

      response-property-type-changed

    • ○

      the response property // became required for the status

      response-property-became-required

    • ○

      the response's property default value {} was removed for the status

      response-property-default-value-removed

    • ●

      the request property's min was set to 0.00

      request-property-min-set

    • ●

      the request property's min was set to 0.00

      request-property-min-set

  • f62be26d2a53943See the full diff
    • ▲

      the response property // became optional for the status

      response-property-became-optional

    • ▲

      the response's property type changed from string to array for status

      response-property-type-changed

    • ▲

      the // response's property type changed from integer to string, and format from uint64 to date-time for status

      response-property-type-changed

    • ▲

      the // response's property type changed from integer to string, and format from uint64 to date-time for status

      response-property-type-changed

    • ▲

      removed the required property from the response with the status

      response-required-property-removed

    • ▲

      removed the required property from the response with the status

      response-required-property-removed

    • ▲

      removed the required property from the response with the status

      response-required-property-removed

    • ▲

      removed the required property from the response with the status

      response-required-property-removed

    • ▲

      removed the required property from the response with the status

      response-required-property-removed

    • ●

      removed the optional property from the response with the status

      response-optional-property-removed

    • ●

      removed the optional property from the response with the status

      response-optional-property-removed

    • ●

      removed the optional property from the response with the status

      response-optional-property-removed

    • ●

      removed the optional property from the response with the status

      response-optional-property-removed

    • ○

      the request property's minLength was decreased from 1 to 0

      request-property-min-length-decreased

    • ○

      removed the pattern ^[a-zA-Z0-9\-/_.=+]+$ from the request property

      request-property-pattern-removed

    • ○

      the response's property default value {} was added for the status

      response-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