kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Stein <joe.st...@stealth.ly>
Subject Re: console producer question
Date Tue, 15 Apr 2014 15:42:12 GMT
Thanks Magnus, very cool!!!! I added it to the client page
https://cwiki.apache.org/confluence/display/KAFKA/Clients

cheers!

/*******************************************
 Joe Stein
 Founder, Principal Consultant
 Big Data Open Source Security LLC
 http://www.stealth.ly
 Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
********************************************/


On Thu, Apr 10, 2014 at 5:23 PM, Ian Friedman <ian@flurry.com> wrote:

> Magnus this worked in our scripts perfectly, thanks a bunch!!
>
> --Ian
>
> On Apr 9, 2014, at 8:39 PM, Magnus Edenhill <magnus@edenhill.se> wrote:
>
> > Hey Ian,
> >
> > this is where a tool like kafkacat comes in handy, it will use a random
> > partitioner by default (without the need for defining a key):
> >
> >  tail -f /my/log | kafkacat -b mybroker -t mytopic
> >
> > See
> > https://github.com/edenhill/kafkacat
> >
> >
> >
> > 2014-04-10 6:13 GMT+07:00 Ian Friedman <ian@flurry.com>:
> >
> >> Hey guys. We recently migrated our production cluster from 0.7.2 to
> 0.8.1.
> >> One of the tools in the 0.7 distribution was something called Producer
> >> Shell, which we used in some cron jobs to do some manual addition of
> >> messages (for messages that got dropped for various reasons). So in 0.8
> >> that is gone, and I have tried replacing it with the console Producer.
> It
> >> seems like the console producer only produces to a single partition
> whereas
> >> the producer shell used to randomly distribute the messages. Is this
> >> behavior configurable? AM I missing something obvious?
> >>
> >> Thanks in advance
> >> --Ian
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message