kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Magnus Edenhill <mag...@edenhill.se>
Subject Re: console producer question
Date Thu, 10 Apr 2014 00:39:55 GMT
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


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

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