gt; However, I'm not getting a message in the consumer. Much thanks for any
> help you can give me. I'm about to ram my head into a wall.
>
--
Chris Bedford
Founder & Lead Lackey
Build Lackey Labs: http://buildlackey.com
Go Grails!: http://blog.buildlackey.com
did all the cleanups above in the code and nothing was
> working till I switched on that param.
>
>
> On Thu, Nov 7, 2013 at 12:15 AM, Chris Bedford >wrote:
>
> > Do you need to use that configuration to get the tests (as currently
> > checked in) to pass
rops.put("auto.offset.reset", "smallest");
>
> Now I can bring up the entire stack in jvm and test like I used to. !
>
>
> On Wed, Nov 6, 2013 at 2:52 AM, Chris Bedford
> wrote:
>
> > Hi, Edward..
> >
> > yup .. you are correct.. when we get to a
t TestKafkaProducer.main(TestKafkaProducer.java:71)
>
>
> On Mon, Nov 4, 2013 at 11:08 PM, Chris Bedford >wrote:
>
> > Hi Ed:
> >
> > regarding the test the testtopology exampe program on my github ...
> > do you see the words " successful completion&
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, "Edw
rtition will
> > > halt
> > > > > and will not resume until the faulty leader node recovers. In this
> > > case,
> > > > > producers should fail the publish request after retrying decent
> > number
> > > of
> > > > > times and provide a callback to the client of the producer to take
> > > > > corrective action. Consumers again have a choice to continue to
> other
> > > > > partitions after retrying decent number of times (in case you are
> > > > fetching
> > > > > from partitions in round robin fashion) or keep retrying until
> leader
> > > is
> > > > > available. In case of latter, the entire consumer process will halt
> > > until
> > > > > the faulty node recovers.
> > > > >
> > > > > Do I have this right?
> > > > >
> > > >
> > >
> >
>
--
Chris Bedford
Founder & Lead Lackey
Build Lackey Labs: http://buildlackey.com
Go Grails!: http://blog.buildlackey.com
houldn't be introducing storm for this simple Kafka example at this point
in any case.
storm
storm
0.9.0-wip17
storm
storm-core
0.9.0-wip17
storm
storm-kafka
0.9.0-wip16a-scala292
--
Chris Bedford
Founder
