[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-18 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170594#comment-16170594 ] Ryan Worsley commented on KAFKA-5825: - You're exactly right [~mjsax]! No wonder they pay you the big

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170564#comment-16170564 ] Matthias J. Sax commented on KAFKA-5825: I just had one more look into your code. Maybe it's just

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-18 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170517#comment-16170517 ] Ryan Worsley commented on KAFKA-5825: - Hi [~apurva], My understanding was that a streams app should

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-18 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170495#comment-16170495 ] Apurva Mehta commented on KAFKA-5825: - I looked at the test log that was shared. It is conclusive that

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170462#comment-16170462 ] Matthias J. Sax commented on KAFKA-5825: [~apurva] Maybe you can provide some input here? >

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-18 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170267#comment-16170267 ] Ryan Worsley commented on KAFKA-5825: - Hi [~guozhang] and [~mjsax] - I'd really appreciate any

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16163954#comment-16163954 ] Guozhang Wang commented on KAFKA-5825: -- I looked carefully through the logs and here is what I can

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-09 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16159834#comment-16159834 ] Ryan Worsley commented on KAFKA-5825: - Hi [~guozhang] did you use the SBT file to satisfy the

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16159375#comment-16159375 ] Guozhang Wang commented on KAFKA-5825: -- I tried to re-run your test code but with no luck to compile.

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154827#comment-16154827 ] Ryan Worsley commented on KAFKA-5825: - Thanks [~guozhang] I don't get any obvious streams issues

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154645#comment-16154645 ] Guozhang Wang commented on KAFKA-5825: -- [~ryanworsley] At the moment I cannot think of any causes on

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154644#comment-16154644 ] Guozhang Wang commented on KAFKA-5825: -- These DEBUG logs are normal, they did not indicate any issues

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154256#comment-16154256 ] Matthias J. Sax commented on KAFKA-5825: I am not sure atm. \cc [~hachikuji] [~apurva] [~guozhang]

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-03 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151923#comment-16151923 ] Ryan Worsley commented on KAFKA-5825: - I've updated the tests to use the {{EmbeddedKafkaCluster}} and

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-03 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151850#comment-16151850 ] Ryan Worsley commented on KAFKA-5825: - Hi [~mjsax] thank you for your reply. In that test I

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151848#comment-16151848 ] Matthias J. Sax commented on KAFKA-5825: For transactions to work, you need to have at least 3