We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 724dd2b commit 794f995Copy full SHA for 794f995
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
@@ -569,6 +569,10 @@ object KafkaMetadataLog extends Logging {
569
// Disable time and byte retention when deleting segments
570
props.setProperty(TopicConfig.RETENTION_MS_CONFIG, "-1")
571
props.setProperty(TopicConfig.RETENTION_BYTES_CONFIG, "-1")
572
+ // AutoMQ for Kafka inject start
573
+ // Override the index interval bytes to 4KB, which is the default value in Apache Kafka.
574
+ props.setProperty(TopicConfig.INDEX_INTERVAL_BYTES_CONFIG, "4096")
575
+ // AutoMQ for Kafka inject end
576
LogConfig.validate(props)
577
val defaultLogConfig = new LogConfig(props)
578
0 commit comments