class KafkaTopicClientImpl implements KafkaTopicClient {

  @Override
  public void createTopic(
      final String topic,
      final int numPartitions,
      final short replicationFactor
  ) {
    createTopic(topic, numPartitions, replicationFactor, Collections.emptyMap());
  }

  public  KafkaTopicClientImpl(final AdminClient adminClient);

}