commit method

void commit(
  1. String metadata
)

Signals that message has been processed and it's offset can be committed (in case of high-level Consumer implementation). In case if consumerGroup functionality is not used (like in the Fetcher) then this method's behaviour will be the same as in ack method.

Implementation

void commit(String metadata) {
  _completer.complete(new _ProcessingResult.commit(metadata));
}