From 92e06b3265e0a95dd83c188767c1608824f835ba Mon Sep 17 00:00:00 2001 From: Ning Yu Date: Wed, 16 Oct 2024 20:45:22 +0800 Subject: [PATCH] perf(kraft): decrease the index interval bytes of KRaft Log from 1MB to 4KB Signed-off-by: Ning Yu --- core/src/main/scala/kafka/raft/KafkaMetadataLog.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala b/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala index 5e107aa148..6640c270e6 100644 --- a/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala +++ b/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala @@ -569,6 +569,10 @@ object KafkaMetadataLog extends Logging { // Disable time and byte retention when deleting segments props.setProperty(TopicConfig.RETENTION_MS_CONFIG, "-1") props.setProperty(TopicConfig.RETENTION_BYTES_CONFIG, "-1") + // AutoMQ for Kafka inject start + // Override the index interval bytes to 4KB, which is the default value in Apache Kafka. + props.setProperty(TopicConfig.INDEX_INTERVAL_BYTES_CONFIG, "4096") + // AutoMQ for Kafka inject end LogConfig.validate(props) val defaultLogConfig = new LogConfig(props)