+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" :
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 = {
val
+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 release of Apache Kafk
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 call
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 docker/
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 mo