Hello, I have read Broker.scala source code, and I found the answer: - With Kafka 0.8.1.1 we used Broker.getConnectionString() in our Java code. - With Kafka 0.8.2.0, this method has been replaced by a 0-arity method without the "get" prefix, so we have to change our Java code to call Broker.connectionString()
So despite binary compatibility is broken, we have a by-pass. I hope this will help other people relying on this API... and I'm going to continue tests with 0.8.2 rc3.. Alex 2015-01-31 21:23 GMT+01:00 Alex The Rocker <alex.m3...@gmail.com>: > Hello, > > I ran my own tests made with kafka_2.10-0.8.1.1.tgz binaries with our > application: > > 1st test: > ====== > replace all kafka .jar files in our application on consumming side > (without recompiling anything) > => tests passed, OK > > 2nd test: > ======= > replace all kafka .jar files in our application on producubg side > (without recompiling anything) > => KO, we get this error: > > 2015-01-31 20:54:00,094 [Timer-2] ERROR c.d.i.t.StdOutErrRedirect - > Exception in thread "Timer-2" > 2015-01-31 20:54:00,111 [Timer-2] ERROR c.d.i.t.StdOutErrRedirect - > java.lang.NoSuchMethodError: > kafka.cluster.Broker.getConnectionString()Ljava/lang/String; > > Which means that binary compatibility with 0.8.1.1 version has been broken. > We use getConnectionString() to get Broker's zookeepers adresses, see this > answer from Neha: > > > http://mail-archives.apache.org/mod_mbox/kafka-users/201404.mbox/%3CCAOG_4QYnWrB=tmrtcryf8-pdagy_cgfe_cxotqbclrkj2+x...@mail.gmail.com%3E > > If the kafka.cluster.Broker.getConnectionString() method has been removed > with Kafka 0.8.2.0, then what is the suitable replacement for it ? > > Thanks > Alex > > >> -----Original Message----- >> From: Jun Rao [mailto:j...@confluent.io] >> Sent: Thursday, January 29, 2015 6:22 >> To: d...@kafka.apache.org; users@kafka.apache.org; >> kafka-clie...@googlegroups.com >> Subject: [VOTE] 0.8.2.0 Candidate 3 >> >> This is the third candidate for release of Apache Kafka 0.8.2.0. >> >> Release Notes for the 0.8.2.0 release >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate3/RELEASE_NOTES.html >> >> *** Please download, test and vote by Saturday, Jan 31, 11:30pm PT >> >> Kafka's KEYS file containing PGP keys we use to sign the release: >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2 >> (SHA256) checksum. >> >> * Release artifacts to be voted upon (source and binary): >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate3/ >> >> * Maven artifacts to be voted upon prior to release: >> https://repository.apache.org/content/groups/staging/ >> >> * scala-doc >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate3/scaladoc/ >> >> * java-doc >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate3/javadoc/ >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag >> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=223ac42a7a2a0dab378cc411f4938a9cea1eb7ea >> (commit 7130da90a9ee9e6fb4beb2a2a6ab05c06c9bfac4) >> >> /******************************************* >> >> Thanks, >> >> Jun >> > >
