|
|
|
CommitOffset (IConsumerRecord)
|
/**
Commit the offset information for a record. This notifies the broker that
the application has completed processing the record. The broker will store the offset
associated with the consumer group the client is part of. By storing the offset with the broker,
the client can recover processing at the next record within the topic if the client needs to be restarted.
*/
|
|
|
|
OpenEdge.Messaging.IConsumerRecord Poll (integer)
|
/**
Request a message from the server to process. The timeout indicates how
much time, in milliseconds, the broker should spend before returning
a response to the client. If there are no records available within the
given time period, this will return the UNKNOWN value.
*/
|