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 >
