code: @Override
    public String getSchema() throws IOException {
      try {
        return this.kafkaSchemaRegistry.getLatestSchemaByTopic(this.topicName);
      } catch (SchemaRegistryException e) {
        throw new RuntimeException(e);
      }
    }
docs: Get the schema (metadata) of the extracted data records.
  
  @return the Kafka topic being extracted
  @throws IOException if there is problem getting the schema