Versions Compared

Key

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

...

Kafka Consumer and Post-Processing as commitcommitSync

To handle the new record to process, we need to make sure that the ones we’ve currently processed are committed.

...

commitSync() is synchronous = blocks until receives response from cluster. And, retries until succeeds or unrecoverable error (retry.backoff.ms = 100 is by default).

Kafka Consumer and Post-Processing as commitAsync