@Override
  public long extract(
      final ConsumerRecord<Object, Object> record,
      final long previousTimestamp
  ) {
    return timestampExtractor.extract(record, previousTimestamp);
  }
@Test
  public void shouldCallInternalTimestampExtractorOnExtract() {
    // Given
    final MetadataTimestampExtractor metadataTimestampExtractor =
        new MetadataTimestampExtractor(timestampExtractor);

    // When
    metadataTimestampExtractor.extract(record, 1);

    // Then
    Mockito.verify(timestampExtractor, Mockito.times(1))
        .extract(record, 1);
  }