Commands

XACK

Marks a pending message as correctly processed, effectively removing it from the pending entries list of the consumer group. Return value of the command is the number of messages successfully acknowledged, that is, the IDs we were actually able to resolve in the PEL.

Read more

XAUTOCLAIM

Changes (or acquires) ownership of messages in a consumer group, as if the messages were delivered to the specified consumer.

Read more

XCLAIM

Changes (or acquires) ownership of a message in a consumer group, as if the message was delivered to the specified consumer.

Read more

XDEL

Removes the specified entries from the stream. Returns the number of items actually deleted, that may be different from the number of IDs passed in case certain IDs do not exist.

Read more

XGROUP CREATECONSUMER

Create a consumer in a consumer group.

Read more

XGROUP DELCONSUMER

Delete a consumer from a consumer group.

Read more

XGROUP SETID

Set a consumer group to an arbitrary last delivered ID value.

Read more

XINFO CONSUMERS

List the consumers in a consumer group

Read more

XINFO GROUPS

List the consumer groups of a stream

Read more

XINFO STREAM

Get information about a stream

Read more

XLEN

Return the number of entries in a stream

Read more

XPENDING

Return information and entries from a stream consumer group pending entries list, that are messages fetched but never acknowledged.

Read more

XRANGE

Return a range of elements in a stream, with IDs matching the specified IDs interval

Read more

XREAD

Return never seen elements in multiple streams, with IDs greater than the ones reported by the caller for each stream. Can block.

Read more

XREADGROUP

Return new entries from a stream using a consumer group, or access the history of the pending entries for a given consumer. Can block.

Read more

XREVRANGE

Return a range of elements in a stream, with IDs matching the specified IDs interval, in reverse order (from greater to smaller IDs) compared to XRANGE

Read more

XSETID

An internal command for replicating stream values

Read more

XTRIM

Trims the stream to (approximately if '~' is passed) a certain size

Read more