Key shared subscription: hash ranges are not fully reported in stats

[eolivelli]

Describe the bug
When I run pulsar-admin topics stats TOPIC-NAME and I have a KeyShared subscription with stickyHashRanges, with many ranges, the stats are not fully reporting the ranges, it looks like that for each consumer they report only the last set of ranges assigned to each Consumer and for some Consumers the list is empty even if the Consumer set the range and it is actually consuming messages.

There should be some bug here:

pulsar/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSelector.java

Line 69 in 9abd6d3

public Map<Consumer, List<Range>> getConsumerKeyHashRanges() {

 public Map<Consumer, List<Range>> getConsumerKeyHashRanges() {
        Map<Consumer, List<Range>> result = new HashMap<>();
        Map.Entry<Integer, Consumer> prev = null;
        for (Map.Entry<Integer, Consumer> entry: rangeMap.entrySet()) {
            if (prev == null) {
                prev = entry;
            } else {
                if (prev.getValue().equals(entry.getValue())) {
                    result.computeIfAbsent(entry.getValue(), key -> new ArrayList<>())
                            .add(Range.of(prev.getKey(), entry.getKey()));
                }
                prev = null;
            }
        }
        return result;
    }

Additional context
Pulsar 2.8.2

[mattisonchao]

Hi, @eolivelli

I can help to fix it.~

[eolivelli]

@mattisonchao I know that @nicoloboschi is already working on a fix

[mattisonchao]

@eolivelli Ah, sorry. I just made a PR, or I'll close it...

[eolivelli]

don't need to close it
#14077

[nicoloboschi]

After having a more detailed look with @eolivelli, we've seen the version used by Enrico is a custom fork based on Pulsar 2.8.0 and it doesn't include #12212, which is the resolution to the problem

@mattisonchao you can close the PR, the problem has been already fixed. Thanks

[codelipenghui]

The issue had no activity for 30 days, mark with Stale label.

[eolivelli]

fixed by #12212