2015-04-17 14:27 GMT+03:00 Victor L :
> Thank you, it is very helpful. I am using zookeeper. Does "rmr /kafka"
> remove zookeeper record associated with topic "kafka"?
>
Yes. But anything will be good if you recreate in some way (manually or by
script) all topics after kafka restart.
> On Fr
Thank you, it is very helpful. I am using zookeeper. Does "rmr /kafka"
remove zookeeper record associated with topic "kafka"?
On Fri, Apr 17, 2015 at 2:50 AM, Alexander Mudryk
wrote:
> Hello!
>
> "Offsetvalue :1065377" likely is coming from Zookeeper.
> Do you use it?
> If so, when you delete/r
Hello!
"Offsetvalue :1065377" likely is coming from Zookeeper.
Do you use it?
If so, when you delete/re-create topics you should clean data in Zookeeper
too. For example:
run
user@host:~$ KAFKA_PATH/bin/zookeeper-shell.sh 127.0.0.1:2181
and type theese commands:
rmr /kafka
create /kafka ''
i have 0.8.1 producer/consumer... I start producer first but when i start
consumer i see the following :
Apr 15 21:26:29 node-1cc1de6d1224 docker[32360]:
INFO|10cf22c161e3|1|consumer|main.go:34|2015/04/15 21:26:29|Starting
ConsumerService
Apr 15 21:26:29 node-1cc1de6d1224 docker[32360]:
INFO|10cf2
