librdkafka-d ~master (2017-04-27T15:04:37Z)

KafkaConsumer.commitAsync

rdkafkad handler kafka_consumer KafkaConsumer

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

Note: This is the asynchronous variant.

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

See Also

KafkaConsummer::commitSync()

Meta

Source

See Implementation

rdkafkad handler kafka_consumer KafkaConsumer constructorsfunctions

Page generated by adrdox