commit method

void commit(
  1. String metadata
)

Signals that batch has been processed and it's offsets can be committed. 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) {
  commitMetadata = metadata;
  _completer.complete(_ProcessingResult.commit(metadata));
}