...
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