@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());
  }
@ 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 ( ) ) ; }
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