add doc after rebalance: KafkaException: fetching topic metadata for topics [Set(default)] from broker [List()] failed

added 1 doc when rebalance 1+3 nodes completed:

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-simple/1.7.7/8095d0b9f7e0a9cd79a663c740e0f8fb31d0e2c8/slf4j-simple-1.7.7.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
INFO - Starting ZkClient event thread.
INFO - Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT
INFO - Client environment:host.name=192.168.1.4
INFO - Client environment:java.version=1.7.0_71
INFO - Client environment:java.vendor=Oracle Corporation
INFO - Client environment:java.home=/Library/Java/JavaVirtualMachines/jdk1.7.0_71.jdk/Contents/Home/jre
INFO - Client environment:java.class.path=/Users/andrei/couchbase_src/kafka_qa/bin:/Users/andrei/.gradle/caches/modules-2/files-2.1/asm/asm/3.1/c157def142714c544bdea2e6144645702adf7097/asm-3.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.101tec/zkclient/0.3/dedcf2b53fb742adba7080ac3aed781694ba616e/zkclient-0.3.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.couchbase.client/core-io/1.2.2/1b6f26f7c17f00747312baf713342214b327ea1d/core-io-1.2.2.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.couchbase.client/kafka-connector/1.2.0/e10d0131b141e4b421a7ac014955dd244bcbeb45/kafka-connector-1.2.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/1.3.9/40719ea6961c0cb6afaeb6a921eaa1f6afd4cfdf/jsr305-1.3.9.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.google.code.gson/gson/2.2.4/a60a5e993c98c864010053cb901b7eab25306568/gson-2.2.4.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.google.guava/guava/16.0.1/5fa98cd1a63c99a44dd8d3b77e4762b066a5d0c5/guava-16.0.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.google.protobuf/protobuf-java/2.5.0/a10732c76bfacdbd633a7eb0f7968b1059a65dfa/protobuf-java-2.5.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.jamesmurty.utils/java-xmlbuilder/0.4/ac5962e48cdee3a0a6e1f8e00fcb594747ac5aaf/java-xmlbuilder-0.4.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.jcraft/jsch/0.1.42/a86104b0f2e0c0bab5b0df836065823a99b5e334/jsch-0.1.42.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-core/1.9/8341846f18187013bb9e27e46b7ee00a6395daf4/jersey-core-1.9.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-json/1.9/1aa73e1896bcc7013fed247157d7f676226eb432/jersey-json-1.9.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-server/1.9/3a6ea7cc5e15c824953f9f3ece2201b634d90d18/jersey-server-1.9.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-impl/2.2.3-1/56baae106392040a45a06d4a41099173425da1e6/jaxb-impl-2.2.3-1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.thoughtworks.paranamer/paranamer/2.3/4a85963a752c0a2f715c3924bfc686865e7e1bc6/paranamer-2.3.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/com.yammer.metrics/metrics-core/2.2.0/f82c035cfa786d3cbec362c38c22a5f5b1bc8724/metrics-core-2.2.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils-core/1.8.0/175dc721f87e4bc5cc0573f990e28c3cf9117508/commons-beanutils-core-1.8.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils/1.7.0/5675fd96b29656504b86029551973d60fb41339b/commons-beanutils-1.7.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-cli/commons-cli/1.2/2bf96b7aa8b611c177d329452af1dc933e14501c/commons-cli-1.2.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-codec/commons-codec/1.6/b7f0fc8f61ecadeb3695f0b9464755eee44374d4/commons-codec-1.6.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-collections/commons-collections/3.2.1/761ea405b9b37ced573d2df0d1e3a4e0f9edc668/commons-collections-3.2.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-configuration/commons-configuration/1.6/32cadde23955d7681b0d94a2715846d20b425235/commons-configuration-1.6.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-daemon/commons-daemon/1.0.13/750856a1fdb3ddf721ccf73c3518e4211cffc3a3/commons-daemon-1.0.13.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-digester/commons-digester/1.8/dc6a73fdbd1fa3f0944e8497c6c872fa21dca37e/commons-digester-1.8.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-el/commons-el/1.0/1df2c042b3f2de0124750241ac6c886dbfa2cc2c/commons-el-1.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-httpclient/commons-httpclient/3.1/964cd74171f427720480efdec40a7c7f6e58426a/commons-httpclient-3.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-io/commons-io/2.4/b1b6ea3b7e4aa4f492509a4952029cd8e48019ad/commons-io-2.4.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-lang/commons-lang/2.6/ce1edb914c94ebc388f086c6827e8bdeec71ac2/commons-lang-2.6.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-logging/commons-logging/1.1.3/f6f66e966c70a83ffbdb6f17a0919eaf7c8aca7f/commons-logging-1.1.3.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/commons-net/commons-net/3.1/2298164a7c2484406f2aa5ac85b205d39019896f/commons-net-3.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/io.netty/netty/3.7.0.Final/7a8c35599c68c0bf383df74469aa3e03d9aca87/netty-3.7.0.Final.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/io.reactivex/rxjava/1.0.15/f0ab8b7c8010cad33b8debda5d09d233571dc486/rxjava-1.0.15.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/javax.activation/activation/1.1/e6cb541461c2834bdea3eb920f1884d1eb508b50/activation-1.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/javax.servlet.jsp/jsp-api/2.1/63f943103f250ef1f3a4d5e94d145a0f961f5316/jsp-api-2.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/javax.servlet/servlet-api/2.5/5959582d97d8b61f4d154ca9e495aafd16726e34/servlet-api-2.5.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/javax.xml.bind/jaxb-api/2.2.2/aeb3021ca93dde265796d82015beecdcff95bf09/jaxb-api-2.2.2.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/javax.xml.stream/stax-api/1.0-2/d6337b0de8b25e53e81b922352fbea9f9f57ba0b/stax-api-1.0-2.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/jline/jline/0.9.94/99a18e9a44834afdebc467294e1138364c207402/jline-0.9.94.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/junit/junit/4.12/2973d150c0dc1fefe998f834810d68f278ea58ec/junit-4.12.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/log4j/log4j/1.2.17/5af35056b4d257e4b64b9e8069c0746e8b08629f/log4j-1.2.17.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/net.java.dev.jets3t/jets3t/0.9.0/792bc96ee7e57b89f472aa0cb5a31015b9f59c96/jets3t-0.9.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/net.jpountz.lz4/lz4/1.2.0/cd301e9a481eae5b68c53267100aeca43b782b9f/lz4-1.2.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/net.sf.jopt-simple/jopt-simple/3.2/d625f12ba08083c8c16dcedd5396ec730e9e77ab/jopt-simple-3.2.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.avro/avro/1.7.4/416e7030879814f52845b97f04bb50ecd1cef372/avro-1.7.4.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-compress/1.4.1/b02e84a993d88568417536240e970c4b809126fd/commons-compress-1.4.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-math3/3.1.1/6719d757a98ff24a83d9d727bef9cec83f59b6e1/commons-math3-3.1.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.curator/curator-client/2.6.0/b9007c357ad1a78066fc6004e8b1feaa2318f6f3/curator-client-2.6.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.curator/curator-framework/2.6.0/81a699c39d127b5b4ff97cc77da7650b53e5b5ed/curator-framework-2.6.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.curator/curator-recipes/2.6.0/8736b0fc42e6bf006d585fe85c90aaa4ade5cbef/curator-recipes-2.6.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.directory.api/api-asn1-api/1.0.0-M20/5e6486ffa3125ba44dc410ead166e1d6ba8ac76d/api-asn1-api-1.0.0-M20.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.directory.api/api-util/1.0.0-M20/a871abf060b3cf83fc6dc4d7e3d151fce50ac3cb/api-util-1.0.0-M20.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.directory.server/apacheds-i18n/2.0.0-M15/71c61c84683152ec2a6a65f3f96fe534e304fa22/apacheds-i18n-2.0.0-M15.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.directory.server/apacheds-kerberos-codec/2.0.0-M15/1c16e4e477183641c5f0dd5cdecd27ec331bacb5/apacheds-kerberos-codec-2.0.0-M15.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-annotations/2.6.0/8cd40a4cde2b77e6edc1ab3bb55706d626ae8b2d/hadoop-annotations-2.6.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-auth/2.6.0/b0b8dec23a84ac8a0d00fbd69a87d320724ae34a/hadoop-auth-2.6.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-common/2.6.0/a3f6d9827e9813a0fb286ebc0d3ae8cffed17105/hadoop-common-2.6.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-hdfs/2.6.0/9e25d4ea9daab5d0b7fbbe1749790aef3280ff35/hadoop-hdfs-2.6.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpclient/4.2.5/666e26e76f2e87d84e4f16acb546481ae1b8e9a6/httpclient-4.2.5.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.2.4/3b7f38df6de5dd8b500e602ae8c2dd5ee446f883/httpcore-4.2.4.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.kafka/kafka-clients/0.8.2.2/a4903cb5fe087be183a50f6c2b08483cff1e8444/kafka-clients-0.8.2.2.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.kafka/kafka_2.10/0.8.2.2/74fb031ad168f243ee511610846c69ea49a8a91b/kafka_2.10-0.8.2.2.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.apache.zookeeper/zookeeper/3.4.6/1b2502e29da1ebaade2357cd1de35a855fa3755/zookeeper-3.4.6.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-core-asl/1.9.13/3c304d70f42f832e0a86d45bd437f692129299a4/jackson-core-asl-1.9.13.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-jaxrs/1.8.3/3604ca9f572170e2ef5813141ec1f0e0100efd19/jackson-jaxrs-1.8.3.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-mapper-asl/1.9.13/1ee2f2bed0e5dd29d1cb155a166e6f8d50bbddb7/jackson-mapper-asl-1.9.13.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-xc/1.8.3/1226667dcdb7c259b3ee07e112ed83446554516e/jackson-xc-1.8.3.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.codehaus.jettison/jettison/1.1/1a01a2a1218fcf9faa2cc2a6ced025bdea687262/jettison-1.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/1.3/42a25dc3219429f0e5d060061f71acb49bf010a0/hamcrest-core-1.3.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.htrace/htrace-core/3.0.4/d7461828faf28411f37f8570d896292db277d838/htrace-core-3.0.4.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/jetty-util/6.1.26/e5642fe0399814e1687d55a3862aa5a3417226a9/jetty-util-6.1.26.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/jetty/6.1.26/2f546e289fddd5b1fab1d4199fbb6e9ef43ee4b0/jetty-6.1.26.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.scala-lang/scala-library/2.10.4/9aae4cb1802537d604e03688cab744ff47b31a7d/scala-library-2.10.4.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.7/2b8019b6249bb05d81d3a3094e468753e2b21311/slf4j-api-1.7.7.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-simple/1.7.7/8095d0b9f7e0a9cd79a663c740e0f8fb31d0e2c8/slf4j-simple-1.7.7.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.tukaani/xz/1.0/ecff5cb8b1189514c9d1d8d68eb77ac372e000c9/xz-1.0.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.1.1.7/33b6965e9364145972035c30a45a996aad2bf789/snappy-java-1.1.1.7.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/tomcat/jasper-compiler/5.5.23/6d35bd7fb8c4fbc1f5401fb3678aa976d2e4c241/jasper-compiler-5.5.23.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/tomcat/jasper-runtime/5.5.23/96ca5528a93ab47b001476b74320c644beb89dde/jasper-runtime-5.5.23.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/xerces/xercesImpl/2.9.1/7bc7e49ddfe4fb5f193ed37ecc96c12292c8ceb6/xercesImpl-2.9.1.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/xml-apis/xml-apis/1.3.04/90b215f48fe42776c8c7f6e3509ec54e84fd65ef/xml-apis-1.3.04.jar:/Users/andrei/.gradle/caches/modules-2/files-2.1/xmlenc/xmlenc/0.52/d82554efbe65906d83b3d97bd7509289e9db561a/xmlenc-0.52.jar
INFO - Client environment:java.library.path=/Users/andrei/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:.
INFO - Client environment:java.io.tmpdir=/var/folders/bg/lx_54l1n4qv3t8y24cj04mxr0000gn/T/
INFO - Client environment:java.compiler=<NA>
INFO - Client environment:os.name=Mac OS X
INFO - Client environment:os.arch=x86_64
INFO - Client environment:os.version=10.10.5
INFO - Client environment:user.name=andrei
INFO - Client environment:user.home=/Users/andrei
INFO - Client environment:user.dir=/Users/andrei/couchbase_src/kafka_qa
INFO - Initiating client connection, connectString=192.168.3.81 sessionTimeout=4000 watcher=org.I0Itec.zkclient.ZkClient@484f47ac
INFO - Opening socket connection to server 192.168.3.81/192.168.3.81:2181. Will not attempt to authenticate using SASL (unknown error)
INFO - Socket connection established to 192.168.3.81/192.168.3.81:2181, initiating session
WARN - Connected to an old server; r-o mode will be unavailable
INFO - Session establishment complete on server 192.168.3.81/192.168.3.81:2181, sessionid = 0x151a7e1123f0015, negotiated timeout = 6000
INFO - zookeeper state changed (SyncConnected)
INFO - CoreEnvironment: {sslEnabled=false, sslKeystoreFile='null', sslKeystorePassword='null', queryEnabled=false, queryPort=8093, bootstrapHttpEnabled=true, bootstrapCarrierEnabled=true, bootstrapHttpDirectPort=8091, bootstrapHttpSslPort=18091, bootstrapCarrierDirectPort=11210, bootstrapCarrierSslPort=11207, ioPoolSize=8, computationPoolSize=8, responseBufferSize=16384, requestBufferSize=16384, kvServiceEndpoints=1, viewServiceEndpoints=1, queryServiceEndpoints=1, ioPool=NioEventLoopGroup, coreScheduler=CoreScheduler, eventBus=DefaultEventBus, packageNameAndVersion=couchbase-jvm-core/1.2.2 (git: 1.2.2-dirty), dcpEnabled=true, retryStrategy=BestEffort, maxRequestLifetime=75000, retryDelay=ExponentialDelay

{growBy 1.0 MICROSECONDS; lower=100, upper=100000}

, reconnectDelay=ExponentialDelay

{growBy 1.0 MILLISECONDS; lower=32, upper=4096}

, observeIntervalDelay=ExponentialDelay

{growBy 1.0 MICROSECONDS; lower=10, upper=100000}

, keepAliveInterval=30000, autoreleaseAfter=2000, bufferPoolingEnabled=true, tcpNodelayEnabled=true, mutationTokensEnabled=false, socketConnectTimeout=1000, dcpConnectionBufferSize=20971520, dcpConnectionBufferAckThreshold=0.2}
INFO - Initiating client connection, connectString=192.168.3.81 sessionTimeout=4000 watcher=org.I0Itec.zkclient.ZkClient@31798517
INFO - Starting ZkClient event thread.
INFO - Opening socket connection to server 192.168.3.81/192.168.3.81:2181. Will not attempt to authenticate using SASL (unknown error)
INFO - Socket connection established to 192.168.3.81/192.168.3.81:2181, initiating session
WARN - Connected to an old server; r-o mode will be unavailable
INFO - Session establishment complete on server 192.168.3.81/192.168.3.81:2181, sessionid = 0x151a7e1123f0016, negotiated timeout = 6000
INFO - zookeeper state changed (SyncConnected)
INFO - Verifying properties
INFO - Property key.serializer.class is overridden to kafka.serializer.StringEncoder
INFO - Property metadata.broker.list is overridden to
INFO - Property serializer.class is overridden to example.SampleEncoder
INFO - Connected to Node couchbase1.vagrant
INFO - Opened bucket default
INFO - Connected to Node couchbase2.vagrant
INFO - Connected to Node couchbase4.vagrant
INFO - Connected to Node couchbase3.vagrant
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_RANGE (0x22, The requested value is outside the legal range)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_RANGE (0x22, The requested value is outside the legal range)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_RANGE (0x22, The requested value is outside the legal range)
WARN - Unexpected status of StreamRequestResponse: ERR_RANGE (0x22, The requested value is outside the legal range)
WARN - Unexpected status of StreamRequestResponse: ERR_RANGE (0x22, The requested value is outside the legal range)
WARN - Unexpected status of StreamRequestResponse: ERR_RANGE (0x22, The requested value is outside the legal range)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_RANGE (0x22, The requested value is outside the legal range)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
WARN - Unexpected status of StreamRequestResponse: ERR_NOT_MY_VBUCKET (0x7, The server is not responsible for the requested vbucket)
ERROR - fetching topic metadata for topics [Set(default)] from broker [List()] failed
kafka.common.KafkaException: fetching topic metadata for topics [Set(default)] from broker [List()] failed
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
at kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:67)
at kafka.utils.Utils$.swallow(Utils.scala:172)
at kafka.utils.Logging$class.swallowError(Logging.scala:106)
at kafka.utils.Utils$.swallowError(Utils.scala:45)
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:67)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36)
at com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
at java.lang.Thread.run(Thread.java:745)
ERROR - Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(default)] from broker [List()] failed
INFO - Back off for 100 ms before retrying send. Remaining retries = 3
ERROR - fetching topic metadata for topics [Set(default)] from broker [List()] failed
kafka.common.KafkaException: fetching topic metadata for topics [Set(default)] from broker [List()] failed
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
at kafka.utils.Utils$.swallow(Utils.scala:172)
at kafka.utils.Logging$class.swallowError(Logging.scala:106)
at kafka.utils.Utils$.swallowError(Utils.scala:45)
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36)
at com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
at java.lang.Thread.run(Thread.java:745)
ERROR - Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(default)] from broker [List()] failed
INFO - Back off for 100 ms before retrying send. Remaining retries = 2
ERROR - fetching topic metadata for topics [Set(default)] from broker [List()] failed
kafka.common.KafkaException: fetching topic metadata for topics [Set(default)] from broker [List()] failed
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
at kafka.utils.Utils$.swallow(Utils.scala:172)
at kafka.utils.Logging$class.swallowError(Logging.scala:106)
at kafka.utils.Utils$.swallowError(Utils.scala:45)
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36)
at com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
at java.lang.Thread.run(Thread.java:745)
ERROR - Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(default)] from broker [List()] failed
INFO - Back off for 100 ms before retrying send. Remaining retries = 1
ERROR - fetching topic metadata for topics [Set(default)] from broker [List()] failed
kafka.common.KafkaException: fetching topic metadata for topics [Set(default)] from broker [List()] failed
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
at kafka.utils.Utils$.swallow(Utils.scala:172)
at kafka.utils.Logging$class.swallowError(Logging.scala:106)
at kafka.utils.Utils$.swallowError(Utils.scala:45)
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36)
at com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
at java.lang.Thread.run(Thread.java:745)
ERROR - Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(default)] from broker [List()] failed
INFO - Back off for 100 ms before retrying send. Remaining retries = 0
ERROR - fetching topic metadata for topics [Set(default)] from broker [List()] failed
kafka.common.KafkaException: fetching topic metadata for topics [Set(default)] from broker [List()] failed
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
at kafka.utils.Utils$.swallow(Utils.scala:172)
at kafka.utils.Logging$class.swallowError(Logging.scala:106)
at kafka.utils.Utils$.swallowError(Utils.scala:45)
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36)
at com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
at java.lang.Thread.run(Thread.java:745)
ERROR - Failed to send requests for topics default with correlation ids in [0,8]
WARN - Exception while Handling DCP Events com.couchbase.kafka.DCPEvent@35c9d465
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75)
at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36)
at com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
at java.lang.Thread.run(Thread.java:745)