@Test
public void topicAlreadyExists() throws Exception {

  String topic = "topic2";
  int partitions = 1;
  Properties props = new Properties();
  props.setProperty(LogConfig.CleanupPolicyProp(), "compact");
  cluster.createTopic(topic, partitions, 1, props);
  try {
    KafkaStoreUtils.checkAndCreateTopic(cluster.zKConnectString(), topic, REPLICAS);
  } catch (RuntimeException e) {
    fail();
  }
}