Deleting a Topic

Call the Admin.deleteTopic(String streamPathAndName, String topicName) method.

Example

public void deleteTopicUtilFunction(String streamPathAndName, String topicName) throws IOException{
	Admin streamAdmin = Streams.newAdmin(conf);
	streamAdmin.deleteTopic(streamPathAndName, topicName);
	streamAdmin.close();		
}

The Javadoc is located here.