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
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