Is the ZK connection string + namespace the same btw the code and the script?
Thanks, Jun On Tue, Feb 25, 2014 at 3:01 AM, David Morales de Frías < dmora...@paradigmatecnologico.com> wrote: > 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(), "");* > > *zkClient.close();* > > > 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? > > > > Regards. >
