@Override
  public Map<String, String> getTopicConfig(final String topicName) {
    return topicConfig(topicName, true);
  }
@Test
  public void shouldHandleRetryableGetTopicConfigError() {
    // Given:
    givenTopicConfigs(
        "fred",
        overriddenConfigEntry(TopicConfig.RETENTION_MS_CONFIG, "12345"),
        defaultConfigEntry(TopicConfig.COMPRESSION_TYPE_CONFIG, "producer")
    );

    when(adminClient.describeConfigs(any()))
        .thenAnswer(describeConfigsResult(new DisconnectException()))
        .thenAnswer(describeConfigsResult());

    // When:
    kafkaTopicClient.getTopicConfig("fred");

    // Then:
    verify(adminClient, times(2)).describeConfigs(any());
  }