Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
Example of custom timestamp extractor
package edu.knoldus.kafka.streams.extraction;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.streams.processor.TimestampExtractor;
public class CustomExtractor implements TimestampExtractor {
@Override
public long extract(ConsumerRecord<Object, Object> consumerRecord, long l) {
return consumerRecord.timestamp() + 60000;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.