kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Morales de Frías <dmora...@paradigmatecnologico.com>
Subject calling ad-hoc topic creation from code
Date Tue, 25 Feb 2014 11:01:54 GMT
Hi there,

I'm trying to create a topic from java code, by calling CreateTopicCommand:

*ZkClient zkClient = new ZkClient(zookeeperCluster, 30000, 30000);*

*CreateTopicCommand.createTopic(zkClient, topic,
numPartitions.intValue(),replicationFactor.intValue(), "");*


The program runs without errors and even if i call it twice, the second
time i receive an exception telling me that this topic already exists.

But, if run a list-topics, the topic doesn't appear... and there is no
folder under kafka-logs

If i want to create it by using the create-topic script, it prints that the
topic already exists¡

Any idea about that?


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message