static String generateTopicName(String baseString) {

    return generateResourceId(
        baseString,
        ILLEGAL_TOPIC_NAME_CHARS,
        REPLACE_TOPIC_NAME_CHAR,
        MAX_TOPIC_NAME_LENGTH,
        TIME_FORMAT);
  }
@Test
  public void testGenerateTopicNameShouldReplaceIllegalChars() {
    String testBaseString = "^apache_beam/io\\kafka\0";
    String actual = KafkaResourceManagerUtils.generateTopicName(testBaseString);
    assertThat(actual).matches("-apache_beam-io-kafka--\\d{8}-\\d{6}-\\d{6}");
  }