Skip to content

Commit

Permalink
Do not suppress state conditions from response array
Browse files Browse the repository at this point in the history
Signed-off-by: Michael Edgar <[email protected]>
  • Loading branch information
MikeEdgar committed Sep 25, 2024
1 parent 16313a2 commit 8639e24
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -124,10 +124,7 @@ KafkaRebalance toKafkaRebalance(io.strimzi.api.kafka.model.rebalance.KafkaRebala
.ifPresent(rebalance.optimizationResult()::putAll);

rebalanceStatus.map(KafkaRebalanceStatus::getConditions).ifPresent(conditions ->
rebalance.conditions(conditions.stream()
.filter(c -> Arrays.stream(KafkaRebalanceState.values())
.noneMatch(stateValue -> stateValue.toString().equals(c.getType())))
.map(Condition::new).toList()));
rebalance.conditions(conditions.stream().map(Condition::new).toList()));

rebalance.addMeta("allowedActions", state
.map(KafkaRebalanceState::getValidAnnotations)
Expand Down

0 comments on commit 8639e24

Please sign in to comment.