KafkaConsumer.commitSync

Commit offsets for the current assignment.

Note: This is the synchronous variant that blocks until offsets are committed or the commit fails (see return value).

Note: If a OffsetCommitCb callback is registered it will be called with commit details on a future call to consume()

ErrorCode.no_error or error code.

  1. ErrorCode commitSync()
    class KafkaConsumer
    nothrow @nogc
    commitSync
    ()
  2. ErrorCode commitSync(Message message)
  3. ErrorCode commitSync(TopicPartition[] offsets)

Meta