> On Aug. 6, 2014, 4:29 a.m., Jun Rao wrote: > > core/src/main/scala/kafka/log/LogCleaner.scala, lines 500-506 > > <https://reviews.apache.org/r/24214/diff/1/?file=649265#file649265line500> > > > > Could we use Compressor.putRecord? Then,we don't have to worry about > > the details of the message format.
Ok.. I will look into Compressor class usage. But Compressor/MemoryRecords/Record classes are part of clients project. Can we use these classes in core? I have not seen these classes usage in core project. > On Aug. 6, 2014, 4:29 a.m., Jun Rao wrote: > > core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala, lines > > 43-51 > > <https://reviews.apache.org/r/24214/diff/1/?file=649266#file649266line43> > > > > Would it be better to make this a parameterized test so that we can > > test all compression codec? Ok.. Will add parameterized tests - Manikumar Reddy ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24214/#review49611 ----------------------------------------------------------- On Aug. 3, 2014, 5:40 p.m., Manikumar Reddy O wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/24214/ > ----------------------------------------------------------- > > (Updated Aug. 3, 2014, 5:40 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-1374 > https://issues.apache.org/jira/browse/KAFKA-1374 > > > Repository: kafka > > > Description > ------- > > LogCleaner code decompresses the compressed messages and writes back the > retained/compacted messages in compressed form > > > Diffs > ----- > > core/src/main/scala/kafka/log/LogCleaner.scala > afbeffc72e7d7706b44961aecf8519c5c5a3b4b1 > core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala > 5bfa764638e92f217d0ff7108ec8f53193c22978 > > Diff: https://reviews.apache.org/r/24214/diff/ > > > Testing > ------- > > > Thanks, > > Manikumar Reddy O > >
