This is an automated email from the ASF dual-hosted git repository. lucasbru pushed a commit to branch kip1071 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 656916309bf4fe046b92951295549f9ee377f7c6 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 b1d0c8f112d..455e48a0c89 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 @@ -1215,7 +1215,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 change only, given that the member will never receive a // new member ID without an epoch (member ID is only assigned when it joins the group). 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 e0e345a0ffc..dd703893e9a 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 @@ -472,8 +472,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) {
