Starting Build
Settings evaluated using settings file '/home/guwang/Workspace/apache/kafka/settings.gradle'.
Projects loaded. Root project using build file '/home/guwang/Workspace/apache/kafka/build.gradle'.
Included projects: [root project 'kafka', project ':clients', project ':contrib', project ':core', project ':examples', project ':perf', project ':contrib:hadoop-consumer', project ':contrib:hadoop-producer']
Evaluating root project 'kafka' using build file '/home/guwang/Workspace/apache/kafka/build.gradle'.
Adding license extension
Adding license extension rule
Adding license extension
Adding license extension rule
Adding license extension
Adding license extension rule
Adding license extension
Adding license extension rule
Adding license extension
Adding license extension rule
Adding license extension
Adding license extension rule
Adding license extension
Adding license extension rule
Adding license tasks for sourceSet licenseMain
The TaskContainer.add() method has been deprecated and is scheduled to be removed in Gradle 2.0. Please use the create() method instead.
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseTest
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseMain
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseTest
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseMain
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseTest
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseMain
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseTest
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseMain
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseTest
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseMain
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseTest
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseMain
Applying license defaults to tasks
Applying license defaults to tasks
Adding license tasks for sourceSet licenseTest
Applying license defaults to tasks
Applying license defaults to tasks
Building project 'core' with Scala version 2.8.0
Building project 'perf' with Scala version 2.8.0
Evaluating project ':clients' using empty build file.
Evaluating project ':contrib' using empty build file.
Evaluating project ':core' using empty build file.
Evaluating project ':examples' using empty build file.
Evaluating project ':perf' using empty build file.
Evaluating project ':contrib:hadoop-consumer' using empty build file.
Evaluating project ':contrib:hadoop-producer' using empty build file.
All projects evaluated.
Selected primary task 'core:test'
Tasks to be executed: [task ':clients:compileJava', task ':clients:processResources', task ':clients:classes', task ':clients:jar', task ':core:compileJava', task ':core:compileScala', task ':core:processResources', task ':core:classes', task ':core:compileTestJava', task ':core:compileTestScala', task ':core:processTestResources', task ':core:testClasses', task ':core:test']
:clients:compileJava
Skipping task ':clients:compileJava' as it is up-to-date.
Skipping task ':clients:compileJava' as it is up-to-date
:clients:compileJava UP-TO-DATE
:clients:processResources
Skipping task ':clients:processResources' as it has no source files.
:clients:processResources UP-TO-DATE
:clients:classes
Skipping task ':clients:classes' as it has no actions.
:clients:classes UP-TO-DATE
:clients:jar
Skipping task ':clients:jar' as it is up-to-date.
Skipping task ':clients:jar' as it is up-to-date
:clients:jar UP-TO-DATE
:core:compileJava
Skipping task ':core:compileJava' as it has no source files.
:core:compileJava UP-TO-DATE
:core:compileScala
:: loading settings :: url = jar:file:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/ivy-2.2.0.jar!/org/apache/ivy/core/settings/ivysettings.xml
Skipping task ':core:compileScala' as it is up-to-date.
Skipping task ':core:compileScala' as it is up-to-date
:core:compileScala UP-TO-DATE
:core:processResources
Skipping task ':core:processResources' as it has no source files.
:core:processResources UP-TO-DATE
:core:classes
Skipping task ':core:classes' as it has no actions.
:core:classes UP-TO-DATE
:core:compileTestJava
Skipping task ':core:compileTestJava' as it has no source files.
:core:compileTestJava UP-TO-DATE
:core:compileTestScala
Executing task ':core:compileTestScala' due to:
  Input file /home/guwang/Workspace/apache/kafka/core/src/test/scala/integration/kafka/api/ProducerSendTest.scala has changed.
Starting Gradle compiler daemon with fork options DaemonForkOptions{minHeapSize=null, maxHeapSize=1024m, jvmArgs=[-XX:MaxPermSize=512m], classpath=[/home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.zinc/zinc/0.2.5/jar/241ee569c0c5e9701ba91bab68481496453a1e63/zinc-0.2.5.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/org.scala-lang/scala-library/2.9.2/jar/55cf429e92d45524a548929a9d6e790205a0e61/scala-library-2.9.2.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.sbt/sbt-interface/0.12.3/jar/d6d0e5d96f15fe7bc795a061c11003c202e959e9/sbt-interface-0.12.3.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/org.scala-lang/scala-compiler/2.9.2/jar/5f0a9beab92705504f8ec79c357f1bb03af2c86a/scala-compiler-2.9.2.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.sbt/incremental-compiler/0.12.3/jar/3f58eb9a3919341fefd4407fa70da393c1a43ea0/incremental-compiler-0.12.3.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.sbt/compiler-interface/0.12.3/jar/bc17f0db63a0a378319f6a6faf12a8586a33fb58/compiler-interface-0.12.3-sources.jar]}.
Starting process 'Gradle Worker 1'. Working directory: /home/guwang/Workspace/apache/kafka Command: /usr/java/jdk1.6.0_38/bin/java -XX:MaxPermSize=512m -Xmx1024m -Dfile.encoding=UTF-8 -cp /home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/gradle-base-services-1.6.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/gradle-core-1.6.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/gradle-cli-1.6.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/gradle-native-1.6.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/gradle-messaging-1.6.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/slf4j-api-1.7.2.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/logback-classic-1.0.9.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/logback-core-1.0.9.jar:/home/guwang/.gradle/wrapper/dists/gradle-1.6-bin/72srdo3a5eb3bic159kar72vok/gradle-1.6/lib/jul-to-slf4j-1.7.2.jar org.gradle.process.internal.launcher.GradleWorkerMain
An attempt to initialize for well behaving parent process finished.
Successfully started process 'Gradle Worker 1'
Started Gradle compiler daemon with fork options DaemonForkOptions{minHeapSize=null, maxHeapSize=1024m, jvmArgs=[-XX:MaxPermSize=512m], classpath=[/home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.zinc/zinc/0.2.5/jar/241ee569c0c5e9701ba91bab68481496453a1e63/zinc-0.2.5.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/org.scala-lang/scala-library/2.9.2/jar/55cf429e92d45524a548929a9d6e790205a0e61/scala-library-2.9.2.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.sbt/sbt-interface/0.12.3/jar/d6d0e5d96f15fe7bc795a061c11003c202e959e9/sbt-interface-0.12.3.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/org.scala-lang/scala-compiler/2.9.2/jar/5f0a9beab92705504f8ec79c357f1bb03af2c86a/scala-compiler-2.9.2.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.sbt/incremental-compiler/0.12.3/jar/3f58eb9a3919341fefd4407fa70da393c1a43ea0/incremental-compiler-0.12.3.jar, /home/guwang/.gradle/caches/artifacts-24/filestore/com.typesafe.sbt/compiler-interface/0.12.3/jar/bc17f0db63a0a378319f6a6faf12a8586a33fb58/compiler-interface-0.12.3-sources.jar]}.
Executing org.gradle.api.internal.tasks.scala.jdk6.ZincScalaCompiler@c2f48d2 in compiler daemon.
Compiling with Zinc Scala compiler.
Compiling 1 Scala source to /home/guwang/Workspace/apache/kafka/core/build/classes/test...
Successfully executed org.gradle.api.internal.tasks.scala.jdk6.ZincScalaCompiler@c2f48d2 in compiler daemon.
:core:processTestResources
Skipping task ':core:processTestResources' as it is up-to-date.
Skipping task ':core:processTestResources' as it is up-to-date
:core:processTestResources UP-TO-DATE
:core:testClasses
Skipping task ':core:testClasses' as it has no actions.
:core:test
Executing task ':core:test' due to:
  Value of input property 'candidateClassFiles' has changed for task ':core:test'
Running single tests with pattern: [**/ProducerSendTest*.class]
Starting process 'Gradle Worker 2'. Working directory: /home/guwang/Workspace/apache/kafka/core Command: /usr/java/jdk1.6.0_38/bin/java -Djava.security.manager=jarjar.org.gradle.process.internal.child.BootstrapSecurityManager -Dfile.encoding=UTF-8 -ea -cp /home/guwang/.gradle/caches/1.6/workerMain/gradle-worker.jar jarjar.org.gradle.process.internal.launcher.GradleWorkerMain
Successfully started process 'Gradle Worker 2'
Gradle Worker 2 executing tests.

kafka.test.ProducerSendTest > testSendToPartition STANDARD_OUT
    [2014-02-10 13:24:26,588] DEBUG Creating new ZookKeeper instance to connect to 127.0.0.1:36715. (org.I0Itec.zkclient.ZkConnection:63)
    [2014-02-10 13:24:26,588] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:64)
    [2014-02-10 13:24:26,665] DEBUG Creating new ZookKeeper instance to connect to 127.0.0.1:36715. (org.I0Itec.zkclient.ZkConnection:63)
    [2014-02-10 13:24:26,665] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:64)

kafka.test.ProducerSendTest > testSendToPartition STANDARD_ERROR
    SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
    SLF4J: Defaulting to no-operation (NOP) logger implementation
    SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.

kafka.test.ProducerSendTest > testSendToPartition STANDARD_OUT
    [2014-02-10 13:24:26,962] DEBUG New event: ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@6bab600f] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:26,962] DEBUG Delivering event #1 ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@6bab600f] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:26,972] DEBUG New event: ZkEvent[Data of /controller_epoch changed sent to kafka.controller.ControllerEpochListener@40bb2bc3] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:27,068] DEBUG New event: ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@2415a94f] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:27,088] DEBUG Creating new ZookKeeper instance to connect to 127.0.0.1:36715. (org.I0Itec.zkclient.ZkConnection:63)
    [2014-02-10 13:24:27,088] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:64)
    [2014-02-10 13:24:27,146] DEBUG Delivering event #1 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:27,146] DEBUG Delivering event #2 ZkEvent[Data of /controller_epoch changed sent to kafka.controller.ControllerEpochListener@40bb2bc3] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:27,150] DEBUG Delivering event #2 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:27,150] DEBUG Delivering event #3 ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@2415a94f] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:27,204] DEBUG New event: ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@2415a94f] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:27,237] DEBUG Delivering event #3 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:27,237] DEBUG Delivering event #4 ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@2415a94f] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:27,286] DEBUG Delivering event #4 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:27,287] DEBUG New event: ZkEvent[Children of /brokers/topics changed sent to kafka.controller.PartitionStateMachine$TopicChangeListener@372943ac] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:27,288] DEBUG Delivering event #5 ZkEvent[Children of /brokers/topics changed sent to kafka.controller.PartitionStateMachine$TopicChangeListener@372943ac] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:27,389] DEBUG Delivering event #5 done (org.I0Itec.zkclient.ZkEventThread:79)
    The message we just sent is marked as [0] : 6
    The message we just sent is marked as [0] : 7
    The message we just sent is marked as [0] : 8
    The message we just sent is marked as [0] : 9
    The message we just sent is marked as [0] : 10
    The message we just sent is marked as [0] : 11
    The message we just sent is marked as [1] : 6
    The message we just sent is marked as [1] : 7
    The message we just sent is marked as [1] : 8
    The message we just sent is marked as [1] : 9
    The message we just sent is marked as [1] : 10
    The message we just sent is marked as [1] : 11
    The message we just sent is marked as [1] : 100
    The message we just sent is marked as [1] : 101
    The message we just sent is marked as [1] : 102
    The message we just sent is marked as [1] : 103
    The message we just sent is marked as [1] : 104
    The message we just sent is marked as [1] : 105
    The message we just sent is marked as [1] : 106
    The message we just sent is marked as [1] : 107
    The message we just sent is marked as [1] : 108
    The message we just sent is marked as [1] : 109
    The message we just sent is marked as [1] : 110
    The message we just sent is marked as [1] : 111
    The message we just sent is marked as [1] : 112
    The message we just sent is marked as [1] : 113
    The message we just sent is marked as [1] : 114
    The message we just sent is marked as [1] : 115
    The message we just sent is marked as [1] : 116
    The message we just sent is marked as [1] : 117
    The message we just sent is marked as [1] : 118
    The message we just sent is marked as [1] : 119
    The message we just sent is marked as [1] : 120
    The message we just sent is marked as [1] : 121
    The message we just sent is marked as [1] : 122
    The message we just sent is marked as [1] : 123
    The message we just sent is marked as [1] : 124
    The message we just sent is marked as [1] : 125
    The message we just sent is marked as [1] : 126
    The message we just sent is marked as [1] : 127
    The message we just sent is marked as [1] : 128
    The message we just sent is marked as [1] : 129
    The message we just sent is marked as [1] : 130
    The message we just sent is marked as [1] : 131
    The message we just sent is marked as [1] : 132
    The message we just sent is marked as [1] : 133
    The message we just sent is marked as [1] : 134
    The message we just sent is marked as [1] : 135
    The message we just sent is marked as [1] : 136
    The message we just sent is marked as [1] : 137
    The message we just sent is marked as [1] : 138
    The message we just sent is marked as [1] : 139
    The message we just sent is marked as [1] : 140
    The message we just sent is marked as [1] : 141
    The message we just sent is marked as [1] : 142
    The message we just sent is marked as [1] : 143
    The message we just sent is marked as [1] : 144
    The message we just sent is marked as [1] : 145
    The message we just sent is marked as [1] : 146
    The message we just sent is marked as [1] : 147
    The message we just sent is marked as [1] : 148
    The message we just sent is marked as [1] : 149
    The message we just sent is marked as [1] : 150
    The message we just sent is marked as [1] : 151
    The message we just sent is marked as [1] : 152
    The message we just sent is marked as [1] : 153
    The message we just sent is marked as [1] : 154
    The message we just sent is marked as [1] : 155
    The message we just sent is marked as [1] : 156
    The message we just sent is marked as [1] : 157
    The message we just sent is marked as [1] : 158
    The message we just sent is marked as [1] : 159
    The message we just sent is marked as [1] : 160
    The message we just sent is marked as [1] : 161
    The message we just sent is marked as [1] : 162
    The message we just sent is marked as [1] : 163
    The message we just sent is marked as [1] : 164
    The message we just sent is marked as [1] : 165
    The message we just sent is marked as [1] : 166
    The message we just sent is marked as [1] : 167
    The message we just sent is marked as [1] : 168
    The message we just sent is marked as [1] : 169
    The message we just sent is marked as [1] : 170
    The message we just sent is marked as [1] : 171
    The message we just sent is marked as [1] : 172
    The message we just sent is marked as [1] : 173
    The message we just sent is marked as [1] : 174
    The message we just sent is marked as [1] : 175
    The message we just sent is marked as [1] : 176
    The message we just sent is marked as [1] : 177
    The message we just sent is marked as [1] : 178
    The message we just sent is marked as [1] : 179
    The message we just sent is marked as [1] : 180
    The message we just sent is marked as [1] : 181
    The message we just sent is marked as [1] : 182
    The message we just sent is marked as [1] : 183
    The message we just sent is marked as [1] : 184
    The message we just sent is marked as [1] : 185
    The message we just sent is marked as [1] : 186
    The message we just sent is marked as [1] : 187
    The message we just sent is marked as [1] : 188
    The message we just sent is marked as [1] : 189
    The message we just sent is marked as [1] : 190
    The message we just sent is marked as [1] : 191
    The message we just sent is marked as [1] : 192
    The message we just sent is marked as [1] : 193
    The message we just sent is marked as [0] : 101
    The message we just sent is marked as [0] : 102
    The message we just sent is marked as [0] : 103
    The message we just sent is marked as [0] : 104
    The message we just sent is marked as [0] : 105
    The message we just sent is marked as [0] : 106
    The message we just sent is marked as [0] : 107
    The message we just sent is marked as [0] : 108
    The message we just sent is marked as [0] : 109
    The message we just sent is marked as [0] : 110
    The message we just sent is marked as [0] : 111
    The message we just sent is marked as [0] : 112
    The message we just sent is marked as [0] : 113
    The message we just sent is marked as [0] : 114
    The message we just sent is marked as [0] : 115
    The message we just sent is marked as [0] : 116
    The message we just sent is marked as [0] : 117
    The message we just sent is marked as [0] : 118
    The message we just sent is marked as [0] : 119
    The message we just sent is marked as [0] : 120
    The message we just sent is marked as [0] : 121
    The message we just sent is marked as [0] : 122
    The message we just sent is marked as [0] : 123
    The message we just sent is marked as [0] : 124
    The message we just sent is marked as [0] : 125
    The message we just sent is marked as [0] : 126
    The message we just sent is marked as [0] : 127
    The message we just sent is marked as [0] : 128
    The message we just sent is marked as [0] : 129
    The message we just sent is marked as [0] : 130
    The message we just sent is marked as [0] : 131
    The message we just sent is marked as [0] : 132
    The message we just sent is marked as [0] : 133
    The message we just sent is marked as [0] : 134
    The message we just sent is marked as [0] : 135
    The message we just sent is marked as [0] : 136
    The message we just sent is marked as [0] : 137
    The message we just sent is marked as [0] : 138
    The message we just sent is marked as [0] : 139
    The message we just sent is marked as [0] : 140
    The message we just sent is marked as [0] : 141
    The message we just sent is marked as [0] : 142
    The message we just sent is marked as [0] : 143
    The message we just sent is marked as [0] : 144
    The message we just sent is marked as [0] : 145
    The message we just sent is marked as [0] : 146
    The message we just sent is marked as [0] : 147
    The message we just sent is marked as [0] : 148
    The message we just sent is marked as [0] : 149
    The message we just sent is marked as [0] : 150
    The message we just sent is marked as [0] : 151
    The message we just sent is marked as [0] : 152
    The message we just sent is marked as [0] : 153
    The message we just sent is marked as [0] : 154
    The message we just sent is marked as [0] : 155
    The message we just sent is marked as [0] : 156
    The message we just sent is marked as [0] : 157
    The message we just sent is marked as [0] : 158
    The message we just sent is marked as [0] : 159
    The message we just sent is marked as [0] : 160
    The message we just sent is marked as [0] : 161
    The message we just sent is marked as [0] : 162
    The message we just sent is marked as [0] : 163
    The message we just sent is marked as [0] : 164
    The message we just sent is marked as [0] : 165
    The message we just sent is marked as [0] : 166
    The message we just sent is marked as [0] : 167
    The message we just sent is marked as [0] : 168
    The message we just sent is marked as [0] : 169
    The message we just sent is marked as [0] : 170
    The message we just sent is marked as [0] : 171
    The message we just sent is marked as [0] : 172
    The message we just sent is marked as [0] : 173
    The message we just sent is marked as [0] : 174
    The message we just sent is marked as [0] : 175
    The message we just sent is marked as [0] : 176
    The message we just sent is marked as [0] : 177
    The message we just sent is marked as [0] : 178
    The message we just sent is marked as [0] : 179
    The message we just sent is marked as [0] : 180
    The message we just sent is marked as [0] : 181
    The message we just sent is marked as [0] : 182
    The message we just sent is marked as [0] : 183
    The message we just sent is marked as [0] : 184
    The message we just sent is marked as [0] : 185
    The message we just sent is marked as [0] : 186
    The message we just sent is marked as [0] : 187
    The message we just sent is marked as [0] : 188
    The message we just sent is marked as [0] : 189
    The message we just sent is marked as [0] : 190
    The message we just sent is marked as [0] : 191
    The message we just sent is marked as [0] : 192
    The message we just sent is marked as [0] : 193
    The message we just sent is marked as [0] : 194
    The message we just sent is marked as [0] : 195
    [2014-02-10 13:24:28,759] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:82)
    [2014-02-10 13:24:28,759] DEBUG Closing ZooKeeper connected to 127.0.0.1:36715 (org.I0Itec.zkclient.ZkConnection:77)
    [2014-02-10 13:24:28,773] DEBUG New event: ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@36e3fd79] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:28,773] DEBUG Delivering event #6 ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@36e3fd79] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:28,780] DEBUG New event: ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@36e3fd79] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:28,784] DEBUG New event: ZkEvent[Data of /controller_epoch changed sent to kafka.controller.ControllerEpochListener@6912d7ae] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:28,815] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:47814 was unsuccessful (kafka.controller.RequestSendThread:103)
    java.net.ConnectException: Connection refused
    	at sun.nio.ch.Net.connect(Native Method)
    	at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
    	at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
    	at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
    	at kafka.controller.RequestSendThread.<init>(ControllerChannelManager.scala:118)
    	at kafka.controller.ControllerChannelManager.kafka$controller$ControllerChannelManager$$addNewBroker(ControllerChannelManager.scala:87)
    	at kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
    	at kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
    	at scala.collection.immutable.Set$Set1.foreach(Set.scala:81)
    	at kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:38)
    	at kafka.controller.KafkaController.startChannelManager(KafkaController.scala:775)
    	at kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:702)
    	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:309)
    	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:161)
    	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
    	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
    	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
    	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
    	at kafka.utils.Utils$.inLock(Utils.scala:538)
    	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
    	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
    	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
    [2014-02-10 13:24:28,826] ERROR [Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send LeaderAndIsr request with correlation id 0 to broker id:1,host:localhost,port:47814. Reconnecting to broker. (kafka.controller.RequestSendThread:103)
    java.nio.channels.ClosedChannelException
    	at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:28,827] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:47814 was unsuccessful (kafka.controller.RequestSendThread:103)
    java.net.ConnectException: Connection refused
    	at sun.nio.ch.Net.connect(Native Method)
    	at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
    	at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
    	at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:28,840] DEBUG New event: ZkEvent[Data of /brokers/topics/topic-1/partitions/0/state changed sent to kafka.utils.LeaderExistsOrChangedListener@4aa193fe] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:24:28,840] DEBUG Delivering event #7 ZkEvent[Data of /brokers/topics/topic-1/partitions/0/state changed sent to kafka.utils.LeaderExistsOrChangedListener@4aa193fe] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:28,843] DEBUG Delivering event #7 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:28,849] DEBUG Delivering event #6 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:28,849] DEBUG Delivering event #8 ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@36e3fd79] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:28,853] DEBUG Delivering event #8 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:28,853] DEBUG Delivering event #9 ZkEvent[Data of /controller_epoch changed sent to kafka.controller.ControllerEpochListener@6912d7ae] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:24:28,855] DEBUG Delivering event #9 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:24:29,128] ERROR [Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send LeaderAndIsr request with correlation id 0 to broker id:1,host:localhost,port:47814. Reconnecting to broker. (kafka.controller.RequestSendThread:103)
    java.nio.channels.ClosedChannelException
    	at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:29,129] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:47814 was unsuccessful (kafka.controller.RequestSendThread:103)
    java.net.ConnectException: Connection refused
    	at sun.nio.ch.Net.connect(Native Method)
    	at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
    	at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
    	at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:29,430] ERROR [Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send LeaderAndIsr request with correlation id 0 to broker id:1,host:localhost,port:47814. Reconnecting to broker. (kafka.controller.RequestSendThread:103)
    java.nio.channels.ClosedChannelException
    	at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:29,431] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:47814 was unsuccessful (kafka.controller.RequestSendThread:103)
    java.net.ConnectException: Connection refused
    	at sun.nio.ch.Net.connect(Native Method)
    	at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
    	at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
    	at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:29,732] ERROR [Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send LeaderAndIsr request with correlation id 0 to broker id:1,host:localhost,port:47814. Reconnecting to broker. (kafka.controller.RequestSendThread:103)
    java.nio.channels.ClosedChannelException
    	at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:29,733] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:47814 was unsuccessful (kafka.controller.RequestSendThread:103)
    java.net.ConnectException: Connection refused
    	at sun.nio.ch.Net.connect(Native Method)
    	at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
    	at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
    	at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
    	at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
    	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
    [2014-02-10 13:24:29,747] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:82)
    [2014-02-10 13:24:29,748] DEBUG Closing ZooKeeper connected to 127.0.0.1:36715 (org.I0Itec.zkclient.ZkConnection:77)
    [2014-02-10 13:24:29,765] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:82)
    [2014-02-10 13:24:29,765] DEBUG Closing ZooKeeper connected to 127.0.0.1:36715 (org.I0Itec.zkclient.ZkConnection:77)
Gradle Worker 2 finished executing tests.

kafka.test.ProducerSendTest > testSendToPartition FAILED
    java.lang.AssertionError: Should have offset 100 expected:<100> but was:<195>
        at org.junit.Assert.fail(Assert.java:69)
        at org.junit.Assert.failNotEquals(Assert.java:314)
        at org.junit.Assert.assertEquals(Assert.java:94)
        at kafka.test.ProducerSendTest.testSendToPartition(ProducerSendTest.scala:223)
Process 'Gradle Worker 2' finished with exit value 0 (state: SUCCEEDED)
Finished generating test XML results (0.038 secs)
Generating HTML test report...
Finished generating test html results (0.041 secs)
:core:test FAILED

BUILD FAILED

Total time: 21.486 secs
Stopping 1 Gradle compiler daemon(s).
Process 'Gradle Worker 1' finished with exit value 0 (state: SUCCEEDED)
Stopped 1 Gradle compiler daemon(s).