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

KafkaConsumer.assign

rdkafkad handler kafka_consumer KafkaConsumer

Update the assignment set to \p partitions.

The assignment set is the set of partitions actually being consumed by the KafkaConsumer.

class KafkaConsumer
nothrow @nogc
ErrorCode
assign
(
const TopicPartition[] partitions
)

Meta

Source

See Implementation

rdkafkad handler kafka_consumer KafkaConsumer constructorsfunctions

Page generated by adrdox