public boolean createTopic(String topicName, int numPartitions) {
    return createTopic(topicName, numPartitions, DEFAULT_REPLICATION_FACTOR);
  }
Creates a kafka topic with the provided name and the number of partitions
@param topicName the name of the topic
@param numPartitions the number of partitions in the topic
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.java