Re: [VOTE] 0.10.2.0 RC1

+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"

Re: [VOTE] 0.10.2.0 RC1

Hi, I am a colleague of Ian's. We use the following processing pipeline in stream app he mentions: https://github.com/zalando-incubator/pipeline-backbone The streams are built using: object Run extends App { // ... private val latch = new CountDownLatch(1) private val builder = {

Re: [VOTE] 0.10.2.0 RC1

+1 (non binding) Checked streams. Verified that stream tests work and examples off confluentinc/examples/kafka-streams work. Thanks Eno > On 10 Feb 2017, at 16:51, Ewen Cheslack-Postava wrote: > > Hello Kafka users, developers and client-developers, > > This is RC1 for

Re: [VOTE] 0.10.2.0 RC1

Hi Ian, thanks for reporting this. I had a look at the stack trace and code and the whole situation is quite confusing. The exception itself is expected but we have a try-catch-block that should swallow the exception and it should never bubble up: In AbstractTaskCreator.retryWithBackoff a

Re: [VOTE] 0.10.2.0 RC1

Seeing the following failure when using multi-threaded streams Feb 10 17:21:15 ip-172-31-137-57 docker/43e65fe123cd[826]: org.apache.kafka.streams.errors.LockException: task [0_21] Failed to lock the state directory: /tmp/kafka-streams/text_pipeline_id/0_21 Feb 10 17:21:15 ip-172-31-137-57

[VOTE] 0.10.2.0 RC1

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