@Test(expected = RuntimeException.class)
public void topicAlreadyExistsButNotCompact() throws Exception {

  String topic = "topic4";
  int partitions = 1;
  cluster.createTopic(topic, partitions, 1);
  KafkaStoreUtils.checkAndCreateTopic(cluster.zKConnectString(), topic, REPLICAS);
}