-1 (non-binding). Whilst testing 0.10.1.1, we found that there's a bug with quotas that means clients can cause broker OOMs very easily. If a producer has exceeded the produce quota, the produce request memory is retained inside the delay queue. (https://issues.apache.org/jira/browse/KAFKA-4725). Seeing as this bug critically impacts broker stability in the face of quota enforcement, I'd like to see a fix landed (we're working on a patch already, see https://github.com/apache/kafka/compare/0.10.1.1...heroku:fix-throttled-response-leak, but it's not quite ready yet).
This bug is still present in 0.10.2.0 RC0 To quote KIP-13 on this matter: > Note that in case of producers, we should be careful about retaining references to large Message bodies because we could easily exhaust broker memory if parking hundreds of requests. Tom Crayford On Thu, Feb 2, 2017 at 8:01 PM, Mathieu Fenniak < mathieu.fenn...@replicon.com> wrote: > +1 (non-binding) > > Upgraded a KS app, custom KC connectors, and brokers, ran an end-to-end > test suite. Looks like a great release to me. :-) > > Mathieu > > > On Wed, Feb 1, 2017 at 4:44 PM, Ewen Cheslack-Postava <e...@confluent.io> > wrote: > > > Hello Kafka users, developers and client-developers, > > > > This is the first candidate 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. > > > > Release notes for the 0.10.2.0 release: > > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc0/RELEASE_NOTES.html > > > > *** Please download, test and vote by Monday February 6th 5pm PST *** > > (Note the longer window to vote to account for the normal 7 days ending > in > > the middle of the weekend.) > > > > 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-rc0/ > > > > * Maven artifacts to be voted upon: > > https://repository.apache.org/content/groups/staging/ > > > > * Javadoc: > > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc0/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= > > 33ebac1f138f17b86002df05e55a9f5cff47f48a > > > > > > * 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/60/ > > System tests: > > https://jenkins.confluent.io/job/system-test-kafka-branch-builder/697 > > > > Thanks, > > Ewen Cheslack-Postava > > >
