KafkaConsumer.commitSync

Commit offsets for the provided list of partitions.

Note: This is the synchronous variant.

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

Meta