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:25:56,989] DEBUG Creating new ZookKeeper instance to connect to 127.0.0.1:33486. (org.I0Itec.zkclient.ZkConnection:63)
    [2014-02-10 13:25:56,989] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:64)
    [2014-02-10 13:25:57,072] DEBUG Creating new ZookKeeper instance to connect to 127.0.0.1:33486. (org.I0Itec.zkclient.ZkConnection:63)
    [2014-02-10 13:25:57,072] 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:25:57,360] DEBUG New event: ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@402fb002] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:25:57,361] DEBUG Delivering event #1 ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@402fb002] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:25:57,370] DEBUG New event: ZkEvent[Data of /controller_epoch changed sent to kafka.controller.ControllerEpochListener@40bb2bc3] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:25:57,482] DEBUG New event: ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@1f758cd1] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:25:57,511] DEBUG Creating new ZookKeeper instance to connect to 127.0.0.1:33486. (org.I0Itec.zkclient.ZkConnection:63)
    [2014-02-10 13:25:57,511] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:64)
    [2014-02-10 13:25:57,570] DEBUG Delivering event #1 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:25:57,570] 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:25:57,575] DEBUG Delivering event #2 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:25:57,576] DEBUG Delivering event #3 ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@1f758cd1] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:25:57,625] DEBUG New event: ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@1f758cd1] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:25:57,658] DEBUG Delivering event #3 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:25:57,658] DEBUG Delivering event #4 ZkEvent[Children of /brokers/ids changed sent to kafka.controller.ReplicaStateMachine$BrokerChangeListener@1f758cd1] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:25:57,705] DEBUG New event: ZkEvent[Children of /brokers/topics changed sent to kafka.controller.PartitionStateMachine$TopicChangeListener@7621447f] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:25:57,711] DEBUG Delivering event #4 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:25:57,711] DEBUG Delivering event #5 ZkEvent[Children of /brokers/topics changed sent to kafka.controller.PartitionStateMachine$TopicChangeListener@7621447f] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:25:57,818] DEBUG Delivering event #5 done (org.I0Itec.zkclient.ZkEventThread:79)
    The message we just sent is marked as [0] : 0
    The message we just sent is marked as [0] : 1
    The message we just sent is marked as [0] : 2
    The message we just sent is marked as [0] : 3
    The message we just sent is marked as [0] : 4
    The message we just sent is marked as [0] : 5
    The message we just sent is marked as [1] : 0
    The message we just sent is marked as [1] : 1
    The message we just sent is marked as [1] : 2
    The message we just sent is marked as [1] : 3
    The message we just sent is marked as [1] : 4
    The message we just sent is marked as [1] : 5
    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] : 12
    The message we just sent is marked as [1] : 13
    The message we just sent is marked as [1] : 14
    The message we just sent is marked as [1] : 15
    The message we just sent is marked as [1] : 16
    The message we just sent is marked as [1] : 17
    The message we just sent is marked as [1] : 18
    The message we just sent is marked as [1] : 19
    The message we just sent is marked as [1] : 20
    The message we just sent is marked as [1] : 21
    The message we just sent is marked as [1] : 22
    The message we just sent is marked as [1] : 23
    The message we just sent is marked as [1] : 24
    The message we just sent is marked as [1] : 25
    The message we just sent is marked as [1] : 26
    The message we just sent is marked as [1] : 27
    The message we just sent is marked as [1] : 28
    The message we just sent is marked as [1] : 29
    The message we just sent is marked as [1] : 30
    The message we just sent is marked as [1] : 31
    The message we just sent is marked as [1] : 32
    The message we just sent is marked as [1] : 33
    The message we just sent is marked as [1] : 34
    The message we just sent is marked as [1] : 35
    The message we just sent is marked as [1] : 36
    The message we just sent is marked as [1] : 37
    The message we just sent is marked as [1] : 38
    The message we just sent is marked as [1] : 39
    The message we just sent is marked as [1] : 40
    The message we just sent is marked as [1] : 41
    The message we just sent is marked as [1] : 42
    The message we just sent is marked as [1] : 43
    The message we just sent is marked as [1] : 44
    The message we just sent is marked as [1] : 45
    The message we just sent is marked as [1] : 46
    The message we just sent is marked as [1] : 47
    The message we just sent is marked as [1] : 48
    The message we just sent is marked as [1] : 49
    The message we just sent is marked as [1] : 50
    The message we just sent is marked as [1] : 51
    The message we just sent is marked as [1] : 52
    The message we just sent is marked as [1] : 53
    The message we just sent is marked as [1] : 54
    The message we just sent is marked as [1] : 55
    The message we just sent is marked as [1] : 56
    The message we just sent is marked as [1] : 57
    The message we just sent is marked as [1] : 58
    The message we just sent is marked as [1] : 59
    The message we just sent is marked as [1] : 60
    The message we just sent is marked as [1] : 61
    The message we just sent is marked as [1] : 62
    The message we just sent is marked as [1] : 63
    The message we just sent is marked as [1] : 64
    The message we just sent is marked as [1] : 65
    The message we just sent is marked as [1] : 66
    The message we just sent is marked as [1] : 67
    The message we just sent is marked as [1] : 68
    The message we just sent is marked as [1] : 69
    The message we just sent is marked as [1] : 70
    The message we just sent is marked as [1] : 71
    The message we just sent is marked as [1] : 72
    The message we just sent is marked as [1] : 73
    The message we just sent is marked as [1] : 74
    The message we just sent is marked as [1] : 75
    The message we just sent is marked as [1] : 76
    The message we just sent is marked as [1] : 77
    The message we just sent is marked as [1] : 78
    The message we just sent is marked as [1] : 79
    The message we just sent is marked as [1] : 80
    The message we just sent is marked as [1] : 81
    The message we just sent is marked as [1] : 82
    The message we just sent is marked as [1] : 83
    The message we just sent is marked as [1] : 84
    The message we just sent is marked as [1] : 85
    The message we just sent is marked as [1] : 86
    The message we just sent is marked as [1] : 87
    The message we just sent is marked as [1] : 88
    The message we just sent is marked as [1] : 89
    The message we just sent is marked as [1] : 90
    The message we just sent is marked as [1] : 91
    The message we just sent is marked as [1] : 92
    The message we just sent is marked as [1] : 93
    The message we just sent is marked as [1] : 94
    The message we just sent is marked as [1] : 95
    The message we just sent is marked as [1] : 96
    The message we just sent is marked as [1] : 97
    The message we just sent is marked as [1] : 98
    The message we just sent is marked as [1] : 99
    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 [0] : 12
    The message we just sent is marked as [0] : 13
    The message we just sent is marked as [0] : 14
    The message we just sent is marked as [0] : 15
    The message we just sent is marked as [0] : 16
    The message we just sent is marked as [0] : 17
    The message we just sent is marked as [0] : 18
    The message we just sent is marked as [0] : 19
    The message we just sent is marked as [0] : 20
    The message we just sent is marked as [0] : 21
    The message we just sent is marked as [0] : 22
    The message we just sent is marked as [0] : 23
    The message we just sent is marked as [0] : 24
    The message we just sent is marked as [0] : 25
    The message we just sent is marked as [0] : 26
    The message we just sent is marked as [0] : 27
    The message we just sent is marked as [0] : 28
    The message we just sent is marked as [0] : 29
    The message we just sent is marked as [0] : 30
    The message we just sent is marked as [0] : 31
    The message we just sent is marked as [0] : 32
    The message we just sent is marked as [0] : 33
    The message we just sent is marked as [0] : 34
    The message we just sent is marked as [0] : 35
    The message we just sent is marked as [0] : 36
    The message we just sent is marked as [0] : 37
    The message we just sent is marked as [0] : 38
    The message we just sent is marked as [0] : 39
    The message we just sent is marked as [0] : 40
    The message we just sent is marked as [0] : 41
    The message we just sent is marked as [0] : 42
    The message we just sent is marked as [0] : 43
    The message we just sent is marked as [0] : 44
    The message we just sent is marked as [0] : 45
    The message we just sent is marked as [0] : 46
    The message we just sent is marked as [0] : 47
    The message we just sent is marked as [0] : 48
    The message we just sent is marked as [0] : 49
    The message we just sent is marked as [0] : 50
    The message we just sent is marked as [0] : 51
    The message we just sent is marked as [0] : 52
    The message we just sent is marked as [0] : 53
    The message we just sent is marked as [0] : 54
    The message we just sent is marked as [0] : 55
    The message we just sent is marked as [0] : 56
    The message we just sent is marked as [0] : 57
    The message we just sent is marked as [0] : 58
    The message we just sent is marked as [0] : 59
    The message we just sent is marked as [0] : 60
    The message we just sent is marked as [0] : 61
    The message we just sent is marked as [0] : 62
    The message we just sent is marked as [0] : 63
    The message we just sent is marked as [0] : 64
    The message we just sent is marked as [0] : 65
    The message we just sent is marked as [0] : 66
    The message we just sent is marked as [0] : 67
    The message we just sent is marked as [0] : 68
    The message we just sent is marked as [0] : 69
    The message we just sent is marked as [0] : 70
    The message we just sent is marked as [0] : 71
    The message we just sent is marked as [0] : 72
    The message we just sent is marked as [0] : 73
    The message we just sent is marked as [0] : 74
    The message we just sent is marked as [0] : 75
    The message we just sent is marked as [0] : 76
    The message we just sent is marked as [0] : 77
    The message we just sent is marked as [0] : 78
    The message we just sent is marked as [0] : 79
    The message we just sent is marked as [0] : 80
    The message we just sent is marked as [0] : 81
    The message we just sent is marked as [0] : 82
    The message we just sent is marked as [0] : 83
    The message we just sent is marked as [0] : 84
    The message we just sent is marked as [0] : 85
    The message we just sent is marked as [0] : 86
    The message we just sent is marked as [0] : 87
    The message we just sent is marked as [0] : 88
    The message we just sent is marked as [0] : 89
    The message we just sent is marked as [0] : 90
    The message we just sent is marked as [0] : 91
    The message we just sent is marked as [0] : 92
    The message we just sent is marked as [0] : 93
    The message we just sent is marked as [0] : 94
    The message we just sent is marked as [0] : 95
    The message we just sent is marked as [0] : 96
    The message we just sent is marked as [0] : 97
    The message we just sent is marked as [0] : 98
    The message we just sent is marked as [0] : 99
    The message we just sent is marked as [0] : 100
    The message we just sent is marked as [1] : 100
    Partition 0 : 101
    Partition 1 : 101
    Partition 0 : 0
    Partition 1 : 100
    [2014-02-10 13:26:00,198] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:82)
    [2014-02-10 13:26:00,199] DEBUG Closing ZooKeeper connected to 127.0.0.1:33486 (org.I0Itec.zkclient.ZkConnection:77)
    [2014-02-10 13:26:00,208] DEBUG New event: ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@469e0c2d] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:26:00,209] DEBUG Delivering event #6 ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@469e0c2d] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:26:00,216] DEBUG New event: ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@469e0c2d] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:26:00,220] DEBUG New event: ZkEvent[Data of /controller_epoch changed sent to kafka.controller.ControllerEpochListener@32162f16] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:26:00,255] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:49735 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:26:00,265] 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:49735. 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:26:00,266] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:49735 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:26:00,276] DEBUG New event: ZkEvent[Data of /brokers/topics/topic-1/partitions/0/state changed sent to kafka.utils.LeaderExistsOrChangedListener@64428527] (org.I0Itec.zkclient.ZkEventThread:88)
    [2014-02-10 13:26:00,276] DEBUG Delivering event #7 ZkEvent[Data of /brokers/topics/topic-1/partitions/0/state changed sent to kafka.utils.LeaderExistsOrChangedListener@64428527] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:26:00,279] DEBUG Delivering event #7 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:26:00,284] DEBUG Delivering event #6 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:26:00,285] DEBUG Delivering event #8 ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@469e0c2d] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:26:00,288] DEBUG Delivering event #8 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:26:00,288] DEBUG Delivering event #9 ZkEvent[Data of /controller_epoch changed sent to kafka.controller.ControllerEpochListener@32162f16] (org.I0Itec.zkclient.ZkEventThread:69)
    [2014-02-10 13:26:00,290] DEBUG Delivering event #9 done (org.I0Itec.zkclient.ZkEventThread:79)
    [2014-02-10 13:26:00,568] 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:49735. 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:26:00,569] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:49735 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:26:00,870] 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:49735. 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:26:00,871] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:49735 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:26:01,173] 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:49735. 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:26:01,174] ERROR [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:49735 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:26:01,224] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:82)
    [2014-02-10 13:26:01,225] DEBUG Closing ZooKeeper connected to 127.0.0.1:33486 (org.I0Itec.zkclient.ZkConnection:77)
    [2014-02-10 13:26:01,242] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread:82)
    [2014-02-10 13:26:01,243] DEBUG Closing ZooKeeper connected to 127.0.0.1:33486 (org.I0Itec.zkclient.ZkConnection:77)
Gradle Worker 2 finished executing tests.
Process 'Gradle Worker 2' finished with exit value 0 (state: SUCCEEDED)
Finished generating test XML results (0.047 secs)
Generating HTML test report...
Finished generating test html results (0.043 secs)

BUILD SUCCESSFUL

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