THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Current state: Under Discussion
Discussion thread: The email not show in archive yet, seemly need wait a while. Here
JIRA: KAFKA-1646
Motivation
...
- Configuration - add one configuration item "log.preallocate", parse it in KafkaConfig.scala, and transfer to KafkaServer.scala, LogConfig.scala.
- In Log.scala
- add one function initFileSize(). if the log preallocation is enabled, the value is config.segmentSize - 2 * config.maxMessageSize, else the value is 0.
- pass the initFileSize and config.preallocate to LogSegment when need create one LogSegment.
- When need roll to a new file, trim log file of active segment
- In LogSegment.scala - pass the initFileSize and preallocation to FileMessageSet.
- In FileMessageSet.scala
- add one function trim(). Call it when close or roll a new LogSegment.
- Move openChannel from CoreUtil.scala and add two more parameter "initFileSize" and "preallocate".
- Add one constructor function with two more parameters "initFileSize" and "preallocate".
- In CoreUtils.scala
- Move openChallel to FileMessageSet.scala
Compatibility, Deprecation, and Migration Plan
...