@Override
  public long extract(
      final ConsumerRecord<Object, Object> record,
      final long previousTimestamp
  ) {
    return timestampExtractor.extract(record, previousTimestamp);
  }
@Test(expected = UnsupportedOperationException.class)
  public void shouldThrowUnsupportedExceptionOnExtractGenericRow() {
    // when/Then
    new MetadataTimestampExtractor(timestampExtractor)
        .extract(mock(Struct.class), mock(GenericRow.class));
  }