diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/strategy/FilterStrategies.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/strategy/FilterStrategies.java index fff57b58..10d51784 100644 --- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/strategy/FilterStrategies.java +++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/strategy/FilterStrategies.java @@ -197,13 +197,13 @@ public class FilterStrategies { } /** - * 检查是否存在存活的客户端POD + * rebalance中数据不进行重试 */ private static final class ReBalanceFilterStrategies implements FilterStrategy { @Override public boolean filter(RetryContext retryContext) { - return ServerNodeBalance.RE_BALANCE_ING.get(); + return !ServerNodeBalance.RE_BALANCE_ING.get(); } @Override diff --git a/example/pom.xml b/example/pom.xml index d6344335..7ee3f413 100644 --- a/example/pom.xml +++ b/example/pom.xml @@ -38,7 +38,7 @@ com.aizuda easy-retry-client-starter - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT com.baomidou