Hi All:
I am trying to programmatically create Topics from a Java client.
I am using a suggestion from
http://stackoverflow.com/questions/16946778/how-can-we-create-a-topic-in-kafka-from-the-ide-using-api/18480684#18480684
Essentially invoking the CreateTopicCommand.main().
String [] arguments = new String[8];
arguments[0] = "--zookeeper";
arguments[1] = "localhost:2181";
arguments[2] = "--replica";
arguments[3] = "1";
arguments[4] = "--partition";
arguments[5] = "5";
arguments[6] = "--topic";
arguments[7] = "someTopicName";
try{
CreateTopicCommand.main(arguments);
}catch(Exception e){
System.out.println("Topic someTopicName exists.");
}
This code works fine the first time it is run (i.e. the Topic does not yet
exist).
Unfortunately, when this is run a second time, an exception is thrown from
Scala that the Java catch block DOES NOT CATCH!
I tried using the ListTopicsCommand, but there is no boolean response to verify
if the topic already exists.
Any suggestions?
thanks
sgg