Hi, I'm trying to package 0.7 using "release-zip" in an attempt to obtain
the usual "tar.gz", but I keep getting failures on unit/integration tests.

Is there something else I shoud do, besides "sbt update release-zip"?

Regards,
Roman

Roman,

Please could you send around the failure stack trace ?

Thanks,
Neha

On Mon, Apr 23, 2012 at 1:09 PM, Roman Garcia <[EMAIL PROTECTED]> wrote:
> Hi, I'm trying to package 0.7 using "release-zip" in an attempt to obtain
> the usual "tar.gz", but I keep getting failures on unit/integration tests.
>
> Is there something else I shoud do, besides "sbt update release-zip"?
>
> Regards,
> Roman

Hi Neha, sorry for the delay...
This are some of the tests I see failing while building src-tar.gz
downloaded from incubator.apache.org...

[error] Test Failed: testCleanupExpiredSegments
junit.framework.AssertionFailedError: Now there should only be only one
segment. expected:<1> but was:<13>
        at junit.framework.Assert.fail(Assert.java:47)
        at junit.framework.Assert.failNotEquals(Assert.java:277)
        at junit.framework.Assert.assertEquals(Assert.java:64)
        at junit.framework.Assert.assertEquals(Assert.java:195)
        at
kafka.log.LogManagerTest.testCleanupExpiredSegments(LogManagerTest.scala:77)

[error] Test Failed: testPartitionedSendToNewTopic
java.lang.AssertionError:
  Unexpected method call send("test-topic1", 0,
ByteBufferMessageSet(MessageAndOffset(message(magic = 1, attributes = 0,
 crc = 2326977762, payload = java.nio.HeapByteBuffer[pos=0 lim=5
cap=5]),15), )):
    close(): expected: 1, actual: 0
        at
org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:45)
        at
org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:73)
        at
org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:92)
        at
kafka.producer.SyncProducer$$EnhancerByCGLIB$$1cc94208.send(<generated>)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:116)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102)
        at
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
        at
scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
        at kafka.producer.ProducerPool.send(ProducerPool.scala:102)
        at kafka.producer.Producer.zkSend(Producer.scala:143)
        at kafka.producer.Producer.send(Producer.scala:105)
        at
kafka.producer.ProducerTest.testPartitionedSendToNewTopic(ProducerTest.scala:564)

[error] Test Failed: testZKSendToExistingTopicWithNoBrokers
junit.framework.AssertionFailedError: Message set should have 1 message
        at junit.framework.Assert.fail(Assert.java:47)
        at junit.framework.Assert.assertTrue(Assert.java:20)
        at
kafka.producer.ProducerTest.testZKSendToExistingTopicWithNoBrokers(ProducerTest.scala:509)

[error] Test Failed: testZKSendToNewTopic
junit.framework.AssertionFailedError: Message set should have 1 message
        at junit.framework.Assert.fail(Assert.java:47)
        at junit.framework.Assert.assertTrue(Assert.java:20)
        at
kafka.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:419)

Any ideas? Is there a way I can "disable" tests (assuming Kafka still
works)?

El 23 de abril de 2012 17:12, Neha Narkhede <[EMAIL PROTECTED]>escribió:

> Roman,
>
> Please could you send around the failure stack trace ?
>
> Thanks,
> Neha
>
> On Mon, Apr 23, 2012 at 1:09 PM, Roman Garcia <[EMAIL PROTECTED]>
> wrote:
> > Hi, I'm trying to package 0.7 using "release-zip" in an attempt to obtain
> > the usual "tar.gz", but I keep getting failures on unit/integration
> tests.
> >
> > Is there something else I shoud do, besides "sbt update release-zip"?
> >
> > Regards,
> > Roman
>

Roman,

This issue has been fixed in trunk. See
https://issues.apache.org/jira/browse/KAFKA-220

Thanks,

Jun

On Mon, Apr 23, 2012 at 2:34 PM, Roman Garcia <[EMAIL PROTECTED]>wrote:

> Hi Neha, sorry for the delay...
> This are some of the tests I see failing while building src-tar.gz
> downloaded from incubator.apache.org...
>
> [error] Test Failed: testCleanupExpiredSegments
> junit.framework.AssertionFailedError: Now there should only be only one
> segment. expected:<1> but was:<13>
>        at junit.framework.Assert.fail(Assert.java:47)
>        at junit.framework.Assert.failNotEquals(Assert.java:277)
>        at junit.framework.Assert.assertEquals(Assert.java:64)
>        at junit.framework.Assert.assertEquals(Assert.java:195)
>        at
>
> kafka.log.LogManagerTest.testCleanupExpiredSegments(LogManagerTest.scala:77)
>
> [error] Test Failed: testPartitionedSendToNewTopic
> java.lang.AssertionError:
>  Unexpected method call send("test-topic1", 0,
> ByteBufferMessageSet(MessageAndOffset(message(magic = 1, attributes = 0,
>  crc = 2326977762, payload = java.nio.HeapByteBuffer[pos=0 lim=5
> cap=5]),15), )):
>    close(): expected: 1, actual: 0
>        at
>
> org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:45)
>        at
>
> org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:73)
>        at
>
> org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:92)
>        at
> kafka.producer.SyncProducer$$EnhancerByCGLIB$$1cc94208.send(<generated>)
>        at
>
> kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:116)
>        at
> kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102)
>        at
> kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102)
>        at
>
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
>        at
> scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
>        at kafka.producer.ProducerPool.send(ProducerPool.scala:102)
>        at kafka.producer.Producer.zkSend(Producer.scala:143)
>        at kafka.producer.Producer.send(Producer.scala:105)
>        at
>
> kafka.producer.ProducerTest.testPartitionedSendToNewTopic(ProducerTest.scala:564)
>
> [error] Test Failed: testZKSendToExistingTopicWithNoBrokers
> junit.framework.AssertionFailedError: Message set should have 1 message
>        at junit.framework.Assert.fail(Assert.java:47)
>        at junit.framework.Assert.assertTrue(Assert.java:20)
>        at
>
> kafka.producer.ProducerTest.testZKSendToExistingTopicWithNoBrokers(ProducerTest.scala:509)
>
> [error] Test Failed: testZKSendToNewTopic
> junit.framework.AssertionFailedError: Message set should have 1 message
>        at junit.framework.Assert.fail(Assert.java:47)
>        at junit.framework.Assert.assertTrue(Assert.java:20)
>        at
> kafka.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:419)
>
> Any ideas? Is there a way I can "disable" tests (assuming Kafka still
> works)?
>
> El 23 de abril de 2012 17:12, Neha Narkhede <[EMAIL PROTECTED]
> >escribió:
>
> > Roman,
> >
> > Please could you send around the failure stack trace ?
> >
> > Thanks,
> > Neha
> >
> > On Mon, Apr 23, 2012 at 1:09 PM, Roman Garcia <[EMAIL PROTECTED]>
> > wrote:
> > > Hi, I'm trying to package 0.7 using "release-zip" in an attempt to
> obtain
> > > the usual "tar.gz", but I keep getting failures on unit/integration
> > tests.
> > >
> > > Is there something else I shoud do, besides "sbt update release-zip"?
> > >
> > > Regards,
> > > Roman
> >
>

Ok, so far no good.
Tests keep failing after fresh check out from latest trunk.
I'm building under cygwin...could that be an issue?

svn co http://svn.apache.org/repos/asf/incubator/kafka/trunk kafka-0.7.0

./sbt update (OK)

./sbt package (OK)

./sbt release-zip (FAIL)

Tests failing:

[error] Error running kafka.integration.LazyInitProducerTest: Test FAILED
[error] Error running kafka.zk.ZKLoadBalanceTest: Test FAILED
[error] Error running kafka.javaapi.producer.ProducerTest: Test FAILED
[error] Error running kafka.producer.ProducerTest: Test FAILED
[error] Error running test: One or more subtasks failed
[error] Error running doc: Scaladoc generation failed

Stacks:
[error] Test Failed: testZKSendWithDeadBroker
junit.framework.AssertionFailedError: Message set should have another
message
        at junit.framework.Assert.fail(Assert.java:47)
        at junit.framework.Assert.assertTrue(Assert.java:20)
        at
kafka.javaapi.producer.ProducerTest.testZKSendWithDeadBroker(ProducerTest.scala:448)
[error] Test Failed: testZKSendToNewTopic
junit.framework.AssertionFailedError: Message set should have 1 message
        at junit.framework.Assert.fail(Assert.java:47)
        at junit.framework.Assert.assertTrue(Assert.java:20)
        at
kafka.javaapi.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:416)
[error] Test Failed: testLoadBalance(kafka.zk.ZKLoadBalanceTest)
junit.framework.AssertionFailedError: expected:<5> but was:<0>
        at junit.framework.Assert.fail(Assert.java:47)
        at junit.framework.Assert.failNotEquals(Assert.java:277)
        at junit.framework.Assert.assertEquals(Assert.java:64)
        at junit.framework.Assert.assertEquals(Assert.java:195)
        at junit.framework.Assert.assertEquals(Assert.java:201)
        at
kafka.zk.ZKLoadBalanceTest.checkSetEqual(ZKLoadBalanceTest.scala:121)
        at
kafka.zk.ZKLoadBalanceTest.testLoadBalance(ZKLoadBalanceTest.scala:89)
[error] Test Failed: testPartitionedSendToNewTopic
java.lang.AssertionError:
  Unexpected method call send("test-topic1", 0,
ByteBufferMessageSet(MessageAndOffset(message(magic = 1, attributes = 0,
crc = 2326977762, payload = java.nio.HeapByteBuffer[pos=0 lim=5
cap=5]),15), )):
    close(): expected: 1, actual: 0
        at
org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:45)
        at
org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:73)
        at
org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:92)
        at
kafka.producer.SyncProducer$$EnhancerByCGLIB$$4385e618.send(<generated>)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:114)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
        at
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
        at
scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
        at kafka.producer.ProducerPool.send(ProducerPool.scala:100)
        at kafka.producer.Producer.zkSend(Producer.scala:137)
        at kafka.producer.Producer.send(Producer.scala:99)
        at
kafka.producer.ProducerTest.testPartitionedSendToNewTopic(ProducerTest.scala:576)
[error] Test Failed: testZKSendToNewTopic
junit.framework.AssertionFailedError: Message set should have 1 message
        at junit.framework.Assert.fail(Assert.java:47)
        at junit.framework.Assert.assertTrue(Assert.java:20)
        at
kafka.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:429)
El 23 de abril de 2012 18:56, Jun Rao <[EMAIL PROTECTED]> escribió:

> Roman,
>
> This issue has been fixed in trunk. See
> https://issues.apache.org/jira/browse/KAFKA-220
>
> Thanks,
>
> Jun
>
> On Mon, Apr 23, 2012 at 2:34 PM, Roman Garcia <[EMAIL PROTECTED]
> >wrote:
>
> > Hi Neha, sorry for the delay...
> > This are some of the tests I see failing while building src-tar.gz

Nevermind...apparently, same steps running in a linux box did the trick.
Its a pity though (and suspicious) that unit/int tests won't run in WIN
environments.

Regards
R

El 24 de abril de 2012 01:36, Roman Garcia <[EMAIL PROTECTED]>escribió:

> Ok, so far no good.
> Tests keep failing after fresh check out from latest trunk.
> I'm building under cygwin...could that be an issue?
>
> svn co http://svn.apache.org/repos/asf/incubator/kafka/trunk kafka-0.7.0
>
> ./sbt update (OK)
>
> ./sbt package (OK)
>
> ./sbt release-zip (FAIL)
>
> Tests failing:
>
> [error] Error running kafka.integration.LazyInitProducerTest: Test FAILED
> [error] Error running kafka.zk.ZKLoadBalanceTest: Test FAILED
> [error] Error running kafka.javaapi.producer.ProducerTest: Test FAILED
> [error] Error running kafka.producer.ProducerTest: Test FAILED
> [error] Error running test: One or more subtasks failed
> [error] Error running doc: Scaladoc generation failed
>
> Stacks:
> [error] Test Failed: testZKSendWithDeadBroker
> junit.framework.AssertionFailedError: Message set should have another
> message
>         at junit.framework.Assert.fail(Assert.java:47)
>         at junit.framework.Assert.assertTrue(Assert.java:20)
>         at
> kafka.javaapi.producer.ProducerTest.testZKSendWithDeadBroker(ProducerTest.scala:448)
> [error] Test Failed: testZKSendToNewTopic
> junit.framework.AssertionFailedError: Message set should have 1 message
>         at junit.framework.Assert.fail(Assert.java:47)
>         at junit.framework.Assert.assertTrue(Assert.java:20)
>          at
> kafka.javaapi.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:416)
> [error] Test Failed: testLoadBalance(kafka.zk.ZKLoadBalanceTest)
> junit.framework.AssertionFailedError: expected:<5> but was:<0>
>          at junit.framework.Assert.fail(Assert.java:47)
>         at junit.framework.Assert.failNotEquals(Assert.java:277)
>         at junit.framework.Assert.assertEquals(Assert.java:64)
>         at junit.framework.Assert.assertEquals(Assert.java:195)
>         at junit.framework.Assert.assertEquals(Assert.java:201)
>         at
> kafka.zk.ZKLoadBalanceTest.checkSetEqual(ZKLoadBalanceTest.scala:121)
>         at
> kafka.zk.ZKLoadBalanceTest.testLoadBalance(ZKLoadBalanceTest.scala:89)
> [error] Test Failed: testPartitionedSendToNewTopic
> java.lang.AssertionError:
>   Unexpected method call send("test-topic1", 0,
> ByteBufferMessageSet(MessageAndOffset(message(magic = 1, attributes = 0,
> crc = 2326977762, payload = java.nio.HeapByteBuffer[pos=0 lim=5
> cap=5]),15), )):
>     close(): expected: 1, actual: 0
>         at
> org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:45)
>         at
> org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:73)
>         at
> org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:92)
>         at
> kafka.producer.SyncProducer$$EnhancerByCGLIB$$4385e618.send(<generated>)
>          at
> kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:114)
>         at
> kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
>         at
> kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
>          at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
>         at
> scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
>         at kafka.producer.ProducerPool.send(ProducerPool.scala:100)
>         at kafka.producer.Producer.zkSend(Producer.scala:137)
>         at kafka.producer.Producer.send(Producer.scala:99)
>         at
> kafka.producer.ProducerTest.testPartitionedSendToNewTopic(ProducerTest.scala:576)
> [error] Test Failed: testZKSendToNewTopic
> junit.framework.AssertionFailedError: Message set should have 1 message
>         at junit.framework.Assert.fail(Assert.java:47)
>         at junit.framework.Assert.assertTrue(Assert.java:20)
>         at
> kafka.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:429)

can you open a JIRA ticket? something that should be looked into

On Tue, Apr 24, 2012 at 1:12 AM, Roman Garcia <[EMAIL PROTECTED]>wrote:

> Nevermind...apparently, same steps running in a linux box did the trick.
> Its a pity though (and suspicious) that unit/int tests won't run in WIN
> environments.
>
> Regards
> R
>
> El 24 de abril de 2012 01:36, Roman Garcia <[EMAIL PROTECTED]
> >escribió:
>
> > Ok, so far no good.
> > Tests keep failing after fresh check out from latest trunk.
> > I'm building under cygwin...could that be an issue?
> >
> > svn co http://svn.apache.org/repos/asf/incubator/kafka/trunk kafka-0.7.0
> >
> > ./sbt update (OK)
> >
> > ./sbt package (OK)
> >
> > ./sbt release-zip (FAIL)
> >
> > Tests failing:
> >
> > [error] Error running kafka.integration.LazyInitProducerTest: Test FAILED
> > [error] Error running kafka.zk.ZKLoadBalanceTest: Test FAILED
> > [error] Error running kafka.javaapi.producer.ProducerTest: Test FAILED
> > [error] Error running kafka.producer.ProducerTest: Test FAILED
> > [error] Error running test: One or more subtasks failed
> > [error] Error running doc: Scaladoc generation failed
> >
> > Stacks:
> > [error] Test Failed: testZKSendWithDeadBroker
> > junit.framework.AssertionFailedError: Message set should have another
> > message
> >         at junit.framework.Assert.fail(Assert.java:47)
> >         at junit.framework.Assert.assertTrue(Assert.java:20)
> >         at
> >
> kafka.javaapi.producer.ProducerTest.testZKSendWithDeadBroker(ProducerTest.scala:448)
> > [error] Test Failed: testZKSendToNewTopic
> > junit.framework.AssertionFailedError: Message set should have 1 message
> >         at junit.framework.Assert.fail(Assert.java:47)
> >         at junit.framework.Assert.assertTrue(Assert.java:20)
> >          at
> >
> kafka.javaapi.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:416)
> > [error] Test Failed: testLoadBalance(kafka.zk.ZKLoadBalanceTest)
> > junit.framework.AssertionFailedError: expected:<5> but was:<0>
> >          at junit.framework.Assert.fail(Assert.java:47)
> >         at junit.framework.Assert.failNotEquals(Assert.java:277)
> >         at junit.framework.Assert.assertEquals(Assert.java:64)
> >         at junit.framework.Assert.assertEquals(Assert.java:195)
> >         at junit.framework.Assert.assertEquals(Assert.java:201)
> >         at
> > kafka.zk.ZKLoadBalanceTest.checkSetEqual(ZKLoadBalanceTest.scala:121)
> >         at
> > kafka.zk.ZKLoadBalanceTest.testLoadBalance(ZKLoadBalanceTest.scala:89)
> > [error] Test Failed: testPartitionedSendToNewTopic
> > java.lang.AssertionError:
> >   Unexpected method call send("test-topic1", 0,
> > ByteBufferMessageSet(MessageAndOffset(message(magic = 1, attributes = 0,
> > crc = 2326977762, payload = java.nio.HeapByteBuffer[pos=0 lim=5
> > cap=5]),15), )):
> >     close(): expected: 1, actual: 0
> >         at
> >
> org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:45)
> >         at
> >
> org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:73)
> >         at
> >
> org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:92)
> >         at
> > kafka.producer.SyncProducer$$EnhancerByCGLIB$$4385e618.send(<generated>)
> >          at
> >
> kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:114)
> >         at
> > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
> >         at
> > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
> >          at
> >
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
> >         at
> > scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
> >         at kafka.producer.ProducerPool.send(ProducerPool.scala:100)
> >         at kafka.producer.Producer.zkSend(Producer.scala:137)
> >         at kafka.producer.Producer.send(Producer.scala:99)
> >         at
> >
> kafka.producer.ProducerTest.testPartitionedSendToNewTopic(ProducerTest.scala:576)
/*
Joe Stein
http://www.linkedin.com/in/charmalloc
Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
*/

Done.
https://issues.apache.org/jira/browse/KAFKA-334

El 24 de abril de 2012 02:19, Joe Stein <[EMAIL PROTECTED]> escribió:

> can you open a JIRA ticket? something that should be looked into
>
> On Tue, Apr 24, 2012 at 1:12 AM, Roman Garcia <[EMAIL PROTECTED]
> >wrote:
>
> > Nevermind...apparently, same steps running in a linux box did the trick.
> > Its a pity though (and suspicious) that unit/int tests won't run in WIN
> > environments.
> >
> > Regards
> > R
> >
> > El 24 de abril de 2012 01:36, Roman Garcia <[EMAIL PROTECTED]
> > >escribió:
> >
> > > Ok, so far no good.
> > > Tests keep failing after fresh check out from latest trunk.
> > > I'm building under cygwin...could that be an issue?
> > >
> > > svn co http://svn.apache.org/repos/asf/incubator/kafka/trunkkafka-0.7.0
> > >
> > > ./sbt update (OK)
> > >
> > > ./sbt package (OK)
> > >
> > > ./sbt release-zip (FAIL)
> > >
> > > Tests failing:
> > >
> > > [error] Error running kafka.integration.LazyInitProducerTest: Test
> FAILED
> > > [error] Error running kafka.zk.ZKLoadBalanceTest: Test FAILED
> > > [error] Error running kafka.javaapi.producer.ProducerTest: Test FAILED
> > > [error] Error running kafka.producer.ProducerTest: Test FAILED
> > > [error] Error running test: One or more subtasks failed
> > > [error] Error running doc: Scaladoc generation failed
> > >
> > > Stacks:
> > > [error] Test Failed: testZKSendWithDeadBroker
> > > junit.framework.AssertionFailedError: Message set should have another
> > > message
> > >         at junit.framework.Assert.fail(Assert.java:47)
> > >         at junit.framework.Assert.assertTrue(Assert.java:20)
> > >         at
> > >
> >
> kafka.javaapi.producer.ProducerTest.testZKSendWithDeadBroker(ProducerTest.scala:448)
> > > [error] Test Failed: testZKSendToNewTopic
> > > junit.framework.AssertionFailedError: Message set should have 1 message
> > >         at junit.framework.Assert.fail(Assert.java:47)
> > >         at junit.framework.Assert.assertTrue(Assert.java:20)
> > >          at
> > >
> >
> kafka.javaapi.producer.ProducerTest.testZKSendToNewTopic(ProducerTest.scala:416)
> > > [error] Test Failed: testLoadBalance(kafka.zk.ZKLoadBalanceTest)
> > > junit.framework.AssertionFailedError: expected:<5> but was:<0>
> > >          at junit.framework.Assert.fail(Assert.java:47)
> > >         at junit.framework.Assert.failNotEquals(Assert.java:277)
> > >         at junit.framework.Assert.assertEquals(Assert.java:64)
> > >         at junit.framework.Assert.assertEquals(Assert.java:195)
> > >         at junit.framework.Assert.assertEquals(Assert.java:201)
> > >         at
> > > kafka.zk.ZKLoadBalanceTest.checkSetEqual(ZKLoadBalanceTest.scala:121)
> > >         at
> > > kafka.zk.ZKLoadBalanceTest.testLoadBalance(ZKLoadBalanceTest.scala:89)
> > > [error] Test Failed: testPartitionedSendToNewTopic
> > > java.lang.AssertionError:
> > >   Unexpected method call send("test-topic1", 0,
> > > ByteBufferMessageSet(MessageAndOffset(message(magic = 1, attributes > 0,
> > > crc = 2326977762, payload = java.nio.HeapByteBuffer[pos=0 lim=5
> > > cap=5]),15), )):
> > >     close(): expected: 1, actual: 0
> > >         at
> > >
> >
> org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:45)
> > >         at
> > >
> >
> org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:73)
> > >         at
> > >
> >
> org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:92)
> > >         at
> > >
> kafka.producer.SyncProducer$$EnhancerByCGLIB$$4385e618.send(<generated>)
> > >          at
> > >
> >
> kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:114)
> > >         at
> > >
> kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
> > >         at
> > >
> kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
> > >          at
> > >
> >
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)