Skip to content

XREADGROUP sticks if reading from history #6494

@kostasrim

Description

@kostasrim

From stream_family.cc:

   if (opts.serve_history)
      range_res = OpRangeFromConsumerPEL(op_args, key, range_opts);
    else
      range_res = OpRange(op_args, key, range_opts);

The issue here is that serve_history is set if at least one of the streams consumes from PEL (not >). If any other stream uses >, it is ignored:

XREADGROUP GROUP mygroup worker1 STREAMS mystream > myother 123-0

We will incorrectly treat mystream as it's reading from history (instead of new messages >) which is a bug

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions