public MultiSchemaInfo getTopicInfo(final String topicName) {
    final Set<SchemaInfo> keySchemasInfo = getTopicSchemas(topicName, IS_KEY_SCHEMA);
    final Set<SchemaInfo> valueSchemasInfo = getTopicSchemas(topicName, IS_VALUE_SCHEMA);

    return new MultiSchemaInfo(keySchemasInfo, valueSchemasInfo);
  }
@Test
    public void shouldThrowIfTopicNameIsNotFound() {
        // When
        final Exception e = assertThrows(
            IllegalArgumentException.class,
            () -> querySchemas.getTopicInfo("t1"));

        // Then
        assertThat(e.getMessage(), is("Unknown topic: t1"));
    }