  @Test
  public void verifySupportTopicThrowsIAEWhenKafkaZkClientIsNull() {

    // Given
    KafkaUtilities kUtil = new KafkaUtilities();

    // When/Then
    try {
      kUtil.verifySupportTopic(null, anyTopic, anyPartitions, anyReplication);
      fail("IllegalArgumentException expected because zkClient is null");
    } catch (NullPointerException e) {
      // ignore
    }
  }