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

  String topic = "topic3";
  int partitions = 2;
  Properties props = new Properties();
  props.setProperty(LogConfig.CleanupPolicyProp(), "compact");
  cluster.createTopic(topic, partitions, 1, props);
  KafkaStoreUtils.checkAndCreateTopic(cluster.zKConnectString(), topic, REPLICAS);
}