Re: log4j dir?

2014-11-14 Thread Ben Drees
Hi, I had trouble with this as well. The version of Kafka I'm running insists on using 'kafka/logs', so I create a soft link from there to the desired destination directory: # kafka scripts hard-code the logs dir, so point that path to where we want the logs to be. ln -s $STREAM_BUFFER_LOGS_DIR

Best way to erase consumer state

2014-12-04 Thread Ben Drees
Hi, What is the best way to erase a stopped, multiprocess consumer's state so that it can be reset (to "smallest offsets", for example) when the consumer is restarted? Deleting /consumers/ from Zookeeper has had the desired effect in the past, but I ran into a situation today where some of the co