Re: kafka-streams TopologyTestDriver problem with EXACTLY_ONCE

2018-04-05 Thread Matthias J. Sax
Thanks Fred! On 4/5/18 3:41 AM, Frederic Arno wrote: > That's what I'm doing now, I override the config from within my tests. > > Reported here: https://issues.apache.org/jira/browse/KAFKA-6749 > > Thanks, Fred > > On 04/04/2018 10:56 PM, Matthias J. Sax wrote: >> Just a side remark. As a worka

Re: kafka-streams TopologyTestDriver problem with EXACTLY_ONCE

2018-04-05 Thread Frederic Arno
That's what I'm doing now, I override the config from within my tests. Reported here: https://issues.apache.org/jira/browse/KAFKA-6749 Thanks, Fred On 04/04/2018 10:56 PM, Matthias J. Sax wrote: Just a side remark. As a workaround it should be fine to remove the config. TopologyTestDriver will

Re: kafka-streams TopologyTestDriver problem with EXACTLY_ONCE

2018-04-04 Thread Matthias J. Sax
Just a side remark. As a workaround it should be fine to remove the config. TopologyTestDriver will not produce duplicates anyway and is also not suitable to test EOS. -Matthias On 4/4/18 1:26 PM, Guozhang Wang wrote: > Thanks Frederic for reporting the issue, I think it is indeed a missing > pie

Re: kafka-streams TopologyTestDriver problem with EXACTLY_ONCE

2018-04-04 Thread Guozhang Wang
Thanks Frederic for reporting the issue, I think it is indeed a missing piece that can be added. Would you mind creating a JIRA for this issue? Guozhang On Wed, Apr 4, 2018 at 8:17 AM, Ted Yu wrote: > You saw the error because TopologyTestDriverTest doesn't explicitly call > MockProducer#ini

Re: kafka-streams TopologyTestDriver problem with EXACTLY_ONCE

2018-04-04 Thread Ted Yu
You saw the error because TopologyTestDriverTest doesn't explicitly call MockProducer#initTransactions(). To do that, TopologyTestDriver needs to expose such method to the TopologyTestDriverTest. You can log a JIRA if you think adding such capability is needed. Cheers On Wed, Apr 4, 2018 at 3:0

kafka-streams TopologyTestDriver problem with EXACTLY_ONCE

2018-04-04 Thread Frederic Arno
Hello, I can't successfully test my processing application which require EXACTLY_ONCE processing guarantee using the new TopologyTestDriver. I always get the following exception: java.lang.IllegalStateException: MockProducer hasn't been initialized for transactions The tests all work fine as