Resetted cluster - kafka.common.KafkaException: Should not set log end offset on partition [test,0]'s local replica 1

Hi, I have a two-node Kafka cluster where I had lost one of the nodes, so I had to re-clone it from the other and since then I have problems with the original node. I went and reseted the whole cluster, deleted the kafka data folders, removed /config, /admin, /brokers, /consumers, /controller and

Re: Resetted cluster - kafka.common.KafkaException: Should not set log end offset on partition [test,0]'s local replica 1

Sorry, I think I found the issue. The host files on the two servers have referenced to the hostnames wrong... Apologies for the question. On Mon, Nov 23, 2015 at 10:12 AM, Zoltan Fedor wrote: > Hi, > I have a two-node Kafka cluster where I had lost one of the nodes, so I > had to re