Skip to main content

Arguments

str
required
The consumer group name.
str
required
The consumer name within the group.
Dict[str, str]
required
A dictionary mapping stream keys to their starting IDs. Use ”>” to read messages never delivered to any consumer in the group.
int
The maximum number of messages to return per stream.
bool
Don’t add messages to the pending entries list (messages won’t need acknowledgment).

Response

Returns a list where each element represents a stream and contains:
  • The stream key
  • A list of messages (ID and field-value pairs)
Returns empty list if no data is available.