kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: kafka-streams TopologyTestDriver problem with EXACTLY_ONCE
Date Wed, 04 Apr 2018 20:26:35 GMT
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 <yuzhihong@gmail.com> wrote:

> 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:03 AM, Frederic Arno <fredericarno@gmail.com>
> wrote:
>
> > 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 soon as I set PROCESSING_GUARANTEE_CONFIG to
> > AT_LEAST_ONCE.
> >
> > Am I doing something wrong?
> >
> > Kafka developpers can reproduce this by adding:
> > put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG,
> > StreamsConfig.EXACTLY_ONCE);
> >
> > to line 88 of TopologyTestDriverTest: streams/test-utils/src/test/ja
> > va/org/apache/kafka/streams/TopologyTestDriverTest.java
> >
> > Thanks, Fred
> >
>



-- 
-- Guozhang

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message