if you want to delete the messages from topic you can use kafka-delete-records.sh. I guess thats whay you are looking for.
Thanks, Kiran On Mon, 4 Feb 2019 at 11:34 AM, Soheil Pourbafrani <soheil.i...@gmail.com> wrote: > I'll try it > For your information, I connect another single node Kafka to the same > Zookeeper cluster and it got data without any error. > In addition, I turned off one of the Kafka nodes and the single remaining > node did the same thing, it created topics but in less than one minutes the > log dir directory change from 0 to 9 Gigabyte data and errors. > > On Mon, Feb 4, 2019 at 7:56 AM ANJANEYA PRASAD NIDUBROLU < > anjaney...@gmail.com> wrote: > > > Can you please try with 3 zookeeper nodes? I guess the leader election is > > not happening correctly due to even number of servers. > > > > Thanks, > > Anji. > > > > On Sun, 3 Feb 2019, 17:27 Soheil Pourbafrani <soheil.i...@gmail.com > wrote: > > > > > Hi, > > > > > > I use Kafka 0.11.3 > > > > > > I delete topics from Kafka using the command *kafka-topic.sh *and > after a > > > while, I observer Kafka just mark topics for deletion while the > > > property *delete.topic.enable > > > *was true! So I stop Kafka cluster and delete the data log directory of > > > Kafka using the command *rm -r /data/** > > > After that, I open the Zookeeper CLI and remove the directory > > > */brokers/topics. > > > *Next, I start the Kafka nodes and it runs as fresh Kafka cluster and I > > > create topics with the same name as those topics I deleted manually. > > > Surprisingly I observe (using the command *du -sh /data/**) the data > > > directory of Kafka change from 0 to 9.0G when I create all topics!!!! > > > > > > There is no producer running and I guess Kafka restore the previous > > deleted > > > topics' data from somewhere (locally not remotely because it reaches > 9.0G > > > in a blink of an eye!) > > > > > > I have 2 Kafka node and 2 Zookeeper node on my cluster. > > > > > > What is the problem with Kafka? > > > > > > -- G.Kiran Kumar
