[KAFKA-1373] LogCleaner assumes first dirty offset zero if there is no cleaner checkpoint

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.1
• Fix Version/s: 0.8.1.1
• Assignee: Joel Jacob Koshy
• Reporter: Joel Jacob Koshy
• Created: 08/Apr/14 21:20
• Updated: 10/Apr/14 23:19
• Resolved: 10/Apr/14 23:19

Description

If you try enabling the compaction policy on a topic that already exists and if its first segment starts with anything other than zero you will see something like this:

java.lang.IllegalArgumentException: requirement failed: Last clean offset is 0 but segment base offset is 2722629 for log test-0.
at scala.Predef$.require(Predef.scala:145)
at kafka.log.Cleaner.buildOffsetMap(LogCleaner.scala:489)
at kafka.log.Cleaner.clean(LogCleaner.scala:287)
at kafka.log.LogCleaner$CleanerThread.cleanOrSleep(LogCleaner.scala:203)
at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:188)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)

Issue Links

• is depended upon by: KAFKA-1380 0.8.1.1 release candidate