om
> > > > wrote:
> > >
> > > > For similar queue related tests we put the check in a loop. Check
> > every
> > > > second until either the result is found or a timeout happens.
> > > >
> > > > -Dave
> > > >
> > > &
second until either the result is found or a timeout happens.
> > >
> > > -Dave
> > >
> > > -Original Message-----
> > > From: Ali Akhtar [mailto:ali.rac...@gmail.com]
> > > Sent: Wednesday, October 19, 2016 3:38 PM
> > > To: users@k
esult is found or a timeout happens.
> >
> > -Dave
> >
> > -Original Message-
> > From: Ali Akhtar [mailto:ali.rac...@gmail.com]
> > Sent: Wednesday, October 19, 2016 3:38 PM
> > To: users@kafka.apache.org
> > Subject: How to block tests of Kafka Streams
r 19, 2016 3:38 PM
> To: users@kafka.apache.org
> Subject: How to block tests of Kafka Streams until messages processed?
>
> I'm using Kafka Streams, and I'm attempting to write integration tests for
> a stream processor.
>
> The processor listens to a topic, processes incoming m
: How to block tests of Kafka Streams until messages processed?
I'm using Kafka Streams, and I'm attempting to write integration tests for a
stream processor.
The processor listens to a topic, processes incoming messages, and writes some
data to Cassandra tables.
I'm attempting to write a test
Wanted to add that there is nothing too special about these utility functions,
they are built using a normal consumer.
Eno
> On 19 Oct 2016, at 21:59, Eno Thereska wrote:
>
> Hi Ali,
>
> Any chance you could recycle some of the code we have in
>
Hi Ali,
Any chance you could recycle some of the code we have in
streams/src/test/java/.../streams/integration/utils? (I know we don't have it
easily accessible in Maven, for now perhaps you could copy to your directory?)
For example there is a method there
I'm using Kafka Streams, and I'm attempting to write integration tests for
a stream processor.
The processor listens to a topic, processes incoming messages, and writes
some data to Cassandra tables.
I'm attempting to write a test which produces some test data, and then
checks whether or not the