Repository: kafka Updated Branches: refs/heads/trunk f20e5108a -> 9b3da9fbf
KAFKA-1739 Remove testComplexCompressDecompress in MessageCompressionTest; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9b3da9fb Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9b3da9fb Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9b3da9fb Branch: refs/heads/trunk Commit: 9b3da9fbfd60e3a0482ec7bd615dc9806cd9941c Parents: f20e510 Author: Manikumar Reddy <[email protected]> Authored: Sun Nov 9 20:23:46 2014 -0800 Committer: Neha Narkhede <[email protected]> Committed: Sun Nov 9 20:24:35 2014 -0800 ---------------------------------------------------------------------- .../scala/unit/kafka/message/MessageCompressionTest.scala | 9 --------- 1 file changed, 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/9b3da9fb/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala b/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala index 0bb275d..76987d4 100644 --- a/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala +++ b/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala @@ -44,15 +44,6 @@ class MessageCompressionTest extends JUnitSuite { assertEquals(messages, decompressed) } - @Test - def testComplexCompressDecompress() { - val messages = List(new Message("hi there".getBytes), new Message("I am fine".getBytes), new Message("I am not so well today".getBytes)) - val message = new ByteBufferMessageSet(compressionCodec = DefaultCompressionCodec, messages = messages.slice(0, 2):_*) - val complexMessages = List(message.shallowIterator.next.message):::messages.slice(2,3) - val complexMessage = new ByteBufferMessageSet(compressionCodec = DefaultCompressionCodec, messages = complexMessages:_*) - val decompressedMessages = complexMessage.iterator.map(_.message).toList - assertEquals(messages, decompressedMessages) - } def isSnappyAvailable(): Boolean = { try {
