Editing a Topic by Increasing Its Number of Partitions

Call the Admin.editTopic(String streamPathAndName, String topicName, int npartitions) method.

Note: The number of partitions can be increased only.

Example

public void editTopicUtilFunction(String streamPathAndName, String topicName, int npartitions) throws IOException{
	Admin streamAdmin = Streams.newAdmin(conf);
	streamAdmin.editTopic(streamPathAndName, topicName, npartitions);
	streamAdmin.close();				
}

The Javadoc is located here.