You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2022/09/01 12:37:16 UTC
[kafka] branch demystify-rebalance-schedule-log created (now 56a5bb3203)
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch demystify-rebalance-schedule-log
in repository https://gitbox.apache.org/repos/asf/kafka.git
at 56a5bb3203 MINOR: Demystify rebalance schedule log
This branch includes the following new commits:
new 56a5bb3203 MINOR: Demystify rebalance schedule log
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[kafka] 01/01: MINOR: Demystify rebalance schedule log
Posted by vv...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a commit to branch demystify-rebalance-schedule-log
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 56a5bb3203b61502558a3772c9573bdf29fe6b11
Author: John Roesler <jo...@vvcephei.org>
AuthorDate: Thu Sep 1 07:36:44 2022 -0500
MINOR: Demystify rebalance schedule log
---
.../kafka/streams/processor/internals/StreamsPartitionAssignor.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
index 2af2fba718..73eb1cfb3e 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
@@ -54,6 +54,7 @@ import org.apache.kafka.streams.state.HostInfo;
import org.slf4j.Logger;
import java.nio.ByteBuffer;
+import java.time.Instant;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
@@ -1355,7 +1356,10 @@ public class StreamsPartitionAssignor implements ConsumerPartitionAssignor, Conf
log.info("Requested to schedule immediate rebalance for new tasks to be safely revoked from current owner.");
nextScheduledRebalanceMs.set(0L);
} else if (encodedNextScheduledRebalanceMs < Long.MAX_VALUE) {
- log.info("Requested to schedule probing rebalance for {} ms.", encodedNextScheduledRebalanceMs);
+ log.info(
+ "Requested to schedule next probing rebalance at {}.",
+ Instant.ofEpochMilli(encodedNextScheduledRebalanceMs) // The Instant#toString format is more readable.
+ );
nextScheduledRebalanceMs.set(encodedNextScheduledRebalanceMs);
} else {
log.info("No followup rebalance was requested, resetting the rebalance schedule.");