Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Kafka 0.8.0 in maven


Copy link to this message
-
Re: Kafka 0.8.0 in maven
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 <[EMAIL PROTECTED]>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" <[EMAIL PROTECTED]> 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?
> >
>