-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24704/
-----------------------------------------------------------
(Updated Oct. 26, 2014, 7:44 a.m.)
Review request for kafka.
Bugs: KAFKA-1499
https://issues.apache.org/jira/browse/KAFKA-1499
Repository: kafka
Description (updated)
-------
Implemented new broker-compression logic. Added a broker-level/topic override
config property compression.type. This config takes the following options:
uncompressed, gzip, snappy, lz4, producer.
Diffs (updated)
-----
core/src/main/scala/kafka/log/Log.scala
157d67369baabd2206a2356b2aa421e848adab17
core/src/main/scala/kafka/log/LogConfig.scala
e48922a97727dd0b98f3ae630ebb0af3bef2373d
core/src/main/scala/kafka/message/BrokerCompression.scala PRE-CREATION
core/src/main/scala/kafka/message/ByteBufferMessageSet.scala
788c7864bc881b935975ab4a4e877b690e65f1f1
core/src/main/scala/kafka/server/KafkaConfig.scala
6e26c5436feb4629d17f199011f3ebb674aa767f
core/src/main/scala/kafka/server/KafkaServer.scala
4de812374e8fb1fed834d2be3f9655f55b511a74
core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala PRE-CREATION
core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala
4e45d965bc423192ac704883ee75e9727006f89b
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
2377abe4933e065d037828a214c3a87e1773a8ef
Diff: https://reviews.apache.org/r/24704/diff/
Testing
-------
Thanks,
Manikumar Reddy O