Package io.hstream
Interface RawRecordReceiver
-
public interface RawRecordReceiverThis interface can be implemented by users ofConsumerto receive raw records.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidprocessRawRecord(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-Responderused to ack producer when received message.
-
-