kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

Couchbase JIRA | Andrei Baranouski | 1 year ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    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)

    Couchbase JIRA | 1 year ago | Andrei Baranouski
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  2. 0

    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)

    Couchbase JIRA | 1 year ago | Andrei Baranouski
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  3. 0

    Can't connect to a remote Kafka producer from windows through java code

    Stack Overflow | 2 years ago | sbgowtham
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Unable to push messages to apache kafka?

    Stack Overflow | 2 years ago | Piyush Kumar
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  6. 0

    Kafka Producer Code FailedToSendMessageException

    Stack Overflow | 2 years ago | chandra sekhar lagadapati
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

    2 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. kafka.common.FailedToSendMessageException

      Failed to send messages after 3 tries.

      at kafka.producer.async.DefaultEventHandler.handle()
    2. Apache Kafka
      Producer.send
      1. kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
      2. kafka.producer.Producer.send(Producer.scala:77)
      3. kafka.javaapi.producer.Producer.send(Producer.scala:33)
      3 frames
    3. com.couchbase.kafka
      KafkaWriter.onEvent
      1. com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75)
      2. com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36)
      2 frames
    4. com.couchbase.client
      BatchEventProcessor.run
      1. com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128)
      1 frame
    5. Java RT
      ThreadPoolExecutor$Worker.run
      1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      2 frames
    6. com.couchbase.client
      DefaultThreadFactory$DefaultRunnableDecorator.run
      1. com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
      1 frame
    7. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame