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