KafkaConsumer.commitSync

Commit offset for a single topic+partition based on \p message

Note: This is the synchronous variant.

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

See Also

KafkaConsummer::commitSync()

Meta