Re: How to block tests of Kafka Streams until messages processed?

2016-10-20 Thread Michael Noll
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 > > > > > > > &

Re: How to block tests of Kafka Streams until messages processed?

2016-10-20 Thread Ali Akhtar
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

Re: How to block tests of Kafka Streams until messages processed?

2016-10-20 Thread Michael Noll
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

Re: How to block tests of Kafka Streams until messages processed?

2016-10-19 Thread Ali Akhtar
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

RE: How to block tests of Kafka Streams until messages processed?

2016-10-19 Thread Tauzell, Dave
: 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

Re: How to block tests of Kafka Streams until messages processed?

2016-10-19 Thread Eno Thereska
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 >

Re: How to block tests of Kafka Streams until messages processed?

2016-10-19 Thread Eno Thereska
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

How to block tests of Kafka Streams until messages processed?

2016-10-19 Thread Ali Akhtar
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