Versions Compared

Old Version 21

changes.mady.by.user thierry sinassamy

Saved on

compared with

New Version 22

changes.mady.by.user thierry sinassamy

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
try{
  for(...){ //Processing batches of records...  }
  //Commit when we know we're done, after the batch is processed
  myConsumer.commitSync();
}catch(CommitFailedException){
  log.error("...");
}

commitSync() is synchronous = blocks until receives response from cluster.