Re: [DISCUSS]: KIP-161: streams record processing exception handlers

2017-05-25 Thread Avi Flax
> On May 25, 2017, at 14:27, Matthias J. Sax wrote: > > Thanks for the KIP Eno! Yes, thank you Eno! It’s very welcome and heartening to see work on this front. I have a few follow-ups to Matthias’ comments: > Why we introduce `ExceptionType` and not just hand in the actual exception? I was w

Re: [DISCUSS] KIP-95: Incremental Batch Processing for Kafka Streams

2016-12-15 Thread Avi Flax
> On Dec 13, 2016, at 21:02, Matthias J. Sax wrote: > > thanks for your feedback. My pleasure! > We want to enlarge the scope for Streams > application and started to collect use cases in the Wiki: > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Data+%28Re%29Processing+Sce

Re: [DISCUSS] KIP-95: Incremental Batch Processing for Kafka Streams

2016-12-13 Thread Avi Flax
On 2016-11-28 13:47 (-0500), "Matthias J. Sax" wrote: > > I want to start a discussion about KIP-95: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-95%3A+Incremental+Batch+Processing+for+Kafka+Streams > > Looking forward to your feedback. Hi Matthias, I’d just like to share some fe

[jira] [Commented] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

2016-12-13 Thread Avi Flax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745978#comment-15745978 ] Avi Flax commented on KAFKA-4437: - Ah, great, thanks! > Incremental Batch Process

[jira] [Commented] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

2016-12-13 Thread Avi Flax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745331#comment-15745331 ] Avi Flax commented on KAFKA-4437: - I have a comment but there doesn’t seem to

Re: Snazzy new look to our website

2016-10-05 Thread Avi Flax
> On Oct 4, 2016, at 19:38, Guozhang Wang wrote: > > The new look is great, thanks Derrick and Gwen! +1 it’s excellent! > > I'm wondering if we should still consider breaking "document.html" into > multiple pages and indexed as sub-topics on the left bar? +1 absolutely, this should _definite

[jira] [Created] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers

2016-06-14 Thread Avi Flax (JIRA)
Avi Flax created KAFKA-3836: --- Summary: KStreamReduce and KTableReduce should not pass nulls to Deserializers Key: KAFKA-3836 URL: https://issues.apache.org/jira/browse/KAFKA-3836 Project: Kafka

[jira] [Commented] (KAFKA-3680) Make Java client classloading more flexible

2016-06-03 Thread Avi Flax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314411#comment-15314411 ] Avi Flax commented on KAFKA-3680: - I’m very much looking forward to this fix! I’m u

Re: Possible bug in Streams → KStreamImpl.java

2016-03-02 Thread Avi Flax
On Mon, Feb 29, 2016 at 6:34 PM, Guozhang Wang wrote: > Thanks for pointing it out! My pleasure! > And yes it is indeed a bug in the code. Could > you file a HOTFIX PR fixing this and also modify the existing unit test to > cover this case? Sorry, I missed your email until just now. I’m glad to

Possible bug in Streams → KStreamImpl.java

2016-02-29 Thread Avi Flax
I was just playing around with Streams’ join features, just to get a feel for them, and I think I may have noticed a bug in the code, in KStreamImpl.java on line 310: https://github.com/apache/kafka/blob/845c6eae1f6c6bcf117f5baa53bb19b4611c0528/streams/src/main/java/org/apache/kafka/streams/kstrea