Also I have my own version of a test driver https://github.com/edwardcapriolo/IronCount/blob/iron-ng/src/test/java/com/jointhegrid/ironcount/IntegrationTest.java
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 <ch...@buildlackey.com>wrote: > Hi Ed: > > regarding the test the testtopology exampe program on my github ... > do you see the words " successful completion" printed out towards the > end of the test Run? > > I assuming that you ran mvn:exec java ...etc.. as specified in the Read Me > file.. is that correct? > On Nov 4, 2013 7:52 PM, "Edward Capriolo" <edlinuxg...@gmail.com> wrote: > > > I am using: > > <dependency> > > <groupId>org.apache.kafka</groupId> > > <artifactId>kafka_2.9.2</artifactId> > > <version>0.8.0-beta1</version> > > </dependency> > > > > I am trying to rebuild iron-count > > https://github.com/edwardcapriolo/IronCount/tree/iron-ng > > against kafka 0.8.0 > > > > I am having considerable issues getting tests to run correctly. > > > > If you run this example > > > > > > > https://github.com/buildlackey/cep/blob/master/kafka-0.8.x/src/main/java/TestKafkaProducer.java > > > > I am writing 2000 messages into a producer..the consumer seems to read > 1200 > > messages or so ...then it never gets any of the rest. > > > > So am I just messing something up or is this release still having the > kinks > > worked out? > > >
