Also I have my own version of a test driver
For Kafka 0.7.0/2 I had a number of integration tests where I could put
messages on a topic and pull them off later. I remember having some issues
setting the batch settings to deal with timing dependencies in tests, but I
have been unable to consume all the methods I produce.
On Mon, Nov 4, 2013 at 11:08 PM, Chris Bedford <[EMAIL PROTECTED]>wrote: