Package io.hstream
Interface RawRecordReceiver
-
public interface RawRecordReceiver
This interface can be implemented by users ofConsumer
to receive raw records.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
processRawRecord(ReceivedRawRecord receivedRawRecord, Responder responder)
Used to consume raw format record.
-
-
-
Method Detail
-
processRawRecord
void processRawRecord(ReceivedRawRecord receivedRawRecord, Responder responder)
Used to consume raw format record.- Parameters:
receivedRawRecord
- record received from producerresponder
-Responder
used to ack producer when received message.
-
-