Hi Matthias and Guozhang, +1 (non-binding)
We eventually solved this on our end. It boiled down to dodgy data and unexpected hidden errors in our processing steps. This eventually resulted in a session time out which triggered the rebalances. Thanks again for all your help. Ian. On 14 February 2017 at 08:06, Moczarski, Swen < smoczar...@ebay-kleinanzeigen.de> wrote: > Thanks a lot for the fast fix! > > I tested my code with the fix and it works fine without exception. > > Regards, > Swen > > Am 2/13/17, 8:38 PM schrieb "Guozhang Wang" <wangg...@gmail.com>: > > Thanks for reporting the JIRA Swen. > > Jason has a patch ready under KAFKA-4761 and I have reviewed it. You > could > try it out and see if it has fixed your issue. > > After this is merged in, we will need another RC. > > > Guozhang > > On Mon, Feb 13, 2017 at 9:52 AM, Moczarski, Swen < > smoczar...@ebay-kleinanzeigen.de> wrote: > > > +0 (non-binding) > > > > Thanks for compiling a new release candidate. > > > > I get an NullPointerException when setting batch.size=0 on producer > > config. This worked before with 0.10.1.1. > > See https://issues.apache.org/jira/browse/KAFKA-4761 > > > > Regards, > > Swen > > > > Am 2/10/17, 5:51 PM schrieb "Ewen Cheslack-Postava" < > e...@confluent.io>: > > > > Hello Kafka users, developers and client-developers, > > > > This is RC1 for release of Apache Kafka 0.10.2.0. > > > > This is a minor version release of Apache Kafka. It includes 19 > new > > KIPs. > > See the release notes and release plan ( > https://cwiki.apache.org/ > > confluence/display/KAFKA/Release+Plan+0.10.2.0) for more > details. A > > few > > feature highlights: SASL-SCRAM support, improved client > compatibility > > to > > allow use of clients newer than the broker, session windows and > global > > tables in the Kafka Streams API, single message transforms in > the Kafka > > Connect framework. > > > > Important note: in addition to the artifacts generated using > JDK7 for > > Scala > > 2.10 and 2.11, this release also includes experimental artifacts > built > > using JDK8 for Scala 2.12. > > > > Important code changes since RC0 (non-docs, non system tests): > > > > * KAFKA-4728; KafkaConsumer#commitSync should copy its input > > * KAFKA-4441; Monitoring incorrect during topic creation and > deletion > > * KAFKA-4734; Trim the time index on old segments > > * KAFKA-4725; Stop leaking messages in produce request body when > > requests > > are delayed > > * KAFKA-4716: Fix case when controller cannot be reached > > > > Release notes for the 0.10.2.0 release: > > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc1/ > RELEASE_NOTES.html > > > > *** Please download, test and vote by Monday, Feb 13, 5pm PT *** > > > > Kafka's KEYS file containing PGP keys we use to sign the release: > > http://kafka.apache.org/KEYS > > > > * Release artifacts to be voted upon (source and binary): > > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc1/ > > > > * Maven artifacts to be voted upon: > > https://repository.apache.org/content/groups/staging/ > > > > * Javadoc: > > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc1/javadoc/ > > > > * Tag to be voted upon (off 0.10.2 branch) is the 0.10.2.0 tag: > > https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h= > > e825b7994bf8c8c4871d1e0973e287e6d31c7ae4 > > > > > > * Documentation: > > http://kafka.apache.org/0102/documentation.html > > > > * Protocol: > > http://kafka.apache.org/0102/protocol.html > > > > * Successful Jenkins builds for the 0.10.2 branch: > > Unit/integration tests: https://builds.apache.org/job/ > > kafka-0.10.2-jdk7/74/ > > System tests: https://jenkins.confluent.io/ > > job/system-test-kafka-0.10.2/25/ > > > > /************************************** > > > > Thanks, > > Ewen > > > > > > > > > -- > -- Guozhang > > >
