File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
common/src/main/java/org/astraea/common/admin Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -643,6 +643,7 @@ public CompletionStage<List<ShareGroup>> shareGroups(Set<String> shareGroupIds)
643643 g .getValue ().groupEpoch (),
644644 g .getValue ().targetAssignmentEpoch (),
645645 shareGroupMetadata .get (g .getKey ()).entrySet ().stream ()
646+ .filter (e -> e .getValue () != null )
646647 .collect (
647648 Collectors .toUnmodifiableMap (
648649 tp -> TopicPartition .from (tp .getKey ()),
@@ -702,6 +703,7 @@ public CompletionStage<List<ConsumerGroup>> consumerGroups(Set<String> consumerG
702703 consumerGroupDescriptions .get (groupId ).type ().toString (),
703704 consumerGroupDescriptions .get (groupId ).coordinator ().id (),
704705 consumerGroupMetadata .get (groupId ).entrySet ().stream ()
706+ .filter (e -> e .getValue () != null )
705707 .collect (
706708 Collectors .toUnmodifiableMap (
707709 tp -> TopicPartition .from (tp .getKey ()),
You can’t perform that action at this time.
0 commit comments