I have success when the number of messages is less then ~1200. With more
then 1200 it never completes.
Try changing the program to this:
tkp = new TestKafkaProducer(
theTopic,
"localhost:" + zookeeperTestServer.getPort(),
4000);
ERROR 23:13:35,900 Thread Thread[main,5,main] died
java.lang.RuntimeException: oh rats... we failed
at TestKafkaProducer.main(TestKafkaProducer.java:71)
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?
> >
>
