public TopicAdmin topicAdmin() {
        return admin.updateAndGet(this::createAdmin);
    }
Get the shared {@link TopicAdmin} instance.

@return the shared instance; never null
@throws ConnectException if this object has already been closed
connect/runtime/src/main/java/org/apache/kafka/connect/util/SharedTopicAdmin.java