KafkaConsumer.commitAsync

Commit offset for the provided list of partitions.

Note: This is the asynchronous variant.

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

Meta