Skip to content

Commit 4cf6824

Browse files
committed
fix(stream): filter consumers by group name in GetConsumerInfo to prevent cross-group leakage
1 parent 27a6d8a commit 4cf6824

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

src/types/redis_stream.cc

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1389,6 +1389,11 @@ rocksdb::Status Stream::GetConsumerInfo(
13891389
continue;
13901390
}
13911391

1392+
// Iterate bounds may include consumers from other groups; verify group name explicitly.
1393+
if (groupNameFromInternalKey(iter->key()) != group_name) {
1394+
continue;
1395+
}
1396+
13921397
std::string consumer_name = consumerNameFromInternalKey(iter->key());
13931398
StreamConsumerMetadata c_metadata = decodeStreamConsumerMetadataValue(iter->value().ToString());
13941399
std::pair<std::string, StreamConsumerMetadata> tmp_item(consumer_name, c_metadata);

0 commit comments

Comments
 (0)