public interface RecordConsumer
Modifier and Type | Method and Description |
---|---|
void |
consume(Record record)
Consume a record.
|
String |
getId()
Return the unique identifier of the records this consumer
will be able to handle.
|
long |
getRevision()
Return the revision this consumer has last seen.
|
void |
setRevision(long revision)
Set the revision this consumer has last seen.
|
String getId()
long getRevision()
void consume(Record record)
record
- record to consumevoid setRevision(long revision)
revision
- revisionCopyright © 2004–2021 The Apache Software Foundation. All rights reserved.