This is an automated email from the ASF dual-hosted git repository.
jsancio pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 0b3ab4687e KIP-835: metadata.max.idle.interval.ms shoud be much bigger
than broker.heartbeat.interval.ms (#12238)
0b3ab4687e is described below
commit 0b3ab4687eec8a463689dccee267361177a27ae7
Author: dengziming <[email protected]>
AuthorDate: Sat Jun 4 02:39:30 2022 +0800
KIP-835: metadata.max.idle.interval.ms shoud be much bigger than
broker.heartbeat.interval.ms (#12238)
The active quorum controller will append NoOpRecord periodically to
increase metadata LEO, however, when a broker startup, we will wait until its
metadata LEO catches up with the controller LEO, we generate NoOpRecord every
500ms and send heartbeat request every 2000ms.
It's almost impossible for a broker to catch up with the controller LEO if
the broker sends a query request every 2000ms but the controller LEO increases
every 500ms, so the tests in KRaftClusterTest will fail.
Reviewers: José Armando García Sancio <[email protected]>,
showuon <[email protected]>, Colin Patrick McCabe
<[email protected]>
---
core/src/main/scala/kafka/server/KafkaConfig.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala
b/core/src/main/scala/kafka/server/KafkaConfig.scala
index 3ed2e3e54d..f751cc21a6 100755
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -81,7 +81,7 @@ object Defaults {
val BrokerHeartbeatIntervalMs = 2000
val BrokerSessionTimeoutMs = 9000
val MetadataSnapshotMaxNewRecordBytes = 20 * 1024 * 1024
- val MetadataMaxIdleIntervalMs = 500
+ val MetadataMaxIdleIntervalMs = 5000
/** KRaft mode configs */
val EmptyNodeId: Int = -1
