Hi, Gaurav, There is already an effort going on for this one: SAMZA-855 <https://issues.apache.org/jira/browse/SAMZA-855>. It would be good if you can try out the patch.
Thanks! -Yi On Mon, Aug 22, 2016 at 1:11 AM, Gaurav Agarwal <gauravagarw...@gmail.com> wrote: > My initial attempt to build against kafka 0.9.0 or 0.10.0 stopped short due > to some non-trivial interface changes and refactorings in Kafka; and I did > not want to make those changes without having a correct understanding. > > Can someone guide me what would be the correct procedure to upgrade this > dependency? Should I attempt to make the build/tests pass against kafka > 0.10 and submit a PR? Or would someone from samza dev team prefer to do > this? > > On Mon, Aug 22, 2016 at 12:36 PM, Gaurav Agarwal <gauravagarw...@gmail.com > > > wrote: > > > Hi All, > > > > What kafka version is supported by Samza release 0.10.1? > > > > In the gradle build file (dependency-versions.gradle) I see it as > kafkaVersion > > = "0.8.2.1". This is very old kafka version and lot of very serious bugs > > have been fixed since then (including the one we are hitting where kafka > > client blocks indefeinitelly in face of betwork hiccups). > > > > Any clues on what version is safe enough to upgrade this dependency to > (if > > I am planning to self build and host the samza binaries privately)? > 0.9.0 / > > 0.10.0 ? > > I noticed that AdminUtils.CreateTopic() call breaks if I take kafka > > 0.10.0. There may be more errors (some may not manifest as directly as > this > > one). > > > > Any plans to upgrade this dependency for samza soon? > > > > https://issues.apache.org/jira/browse/KAFKA-1733 > > -- > > --cheers, gaurav > > >
