This is an automated email from the ASF dual-hosted git repository. cadonna pushed a commit to branch kip1071 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit a002fe9c241b5b982d70e7818ea23e077f9b629e Author: Lucas Brutschy <[email protected]> AuthorDate: Tue Aug 20 11:14:17 2024 +0200 Minor: Revert test changes --- .../kafka/clients/consumer/internals/AbstractMembershipManager.java | 1 - .../processor/internals/assignment/TaskAssignorConvergenceTest.java | 4 ++-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java index 049944ed09f..c6aa70d805e 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java @@ -1270,7 +1270,6 @@ public abstract class AbstractMembershipManager<R extends AbstractResponse> impl protected void updateMemberEpoch(int newEpoch) { boolean newEpochReceived = this.memberEpoch != newEpoch; - log.info("Updating member epoch to {}", newEpoch); this.memberEpoch = newEpoch; // Simply notify based on epoch changes only, since the member will generate a member ID // at startup, and it will remain unchanged for its entire lifetime. diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java index 19eb361a1d3..936c9eb6a85 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java @@ -471,8 +471,8 @@ public class TaskAssignorConvergenceTest { @ParameterizedTest @ValueSource(strings = { -// StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_NONE, -// StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_MIN_TRAFFIC, + StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_NONE, + StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_MIN_TRAFFIC, StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_BALANCE_SUBTOPOLOGY }) public void randomClusterPerturbationsShouldConverge(final String rackAwareStrategy) {
