- SequenceNumberExtractor<String, String> extractor =
- new SequenceNumberExtractor<String, String>() {
- @Override
- public long extract(
- String topic, int partition, long offset, Headers headers, String key, String value)
- {
- return Long.parseLong(value);
- }
- };
-