@Override
  public Map<String, String> getTopicConfig(final String topicName) {
    return topicConfig(topicName, true);
  }
@Test
  public void shouldThrowKsqlTopicAuthorizationExceptionFromGetTopicConfig() {
    // Given:
    final String topicName = "foobar";
    when(adminClient.describeConfigs(ImmutableList.of(topicResource(topicName))))
        .thenAnswer(describeConfigsResult(new TopicAuthorizationException(ImmutableSet.of(topicName))));

    // When:
    final Exception e = assertThrows(
        KsqlTopicAuthorizationException.class,
        () -> kafkaTopicClient.getTopicConfig(topicName)
    );

    // Then:
    assertThat(e.getMessage(), containsString(
        "Authorization denied to Describe_configs on topic(s): [" + topicName + "]"));
  }