KafkaConsumer.close

Close and shut down the proper.

This call will block until the following operations are finished: - Trigger a local rebalance to void the current assignment - Stop consumption for current assignment - Commit offsets - Leave group

The maximum blocking time is roughly limited to session.timeout.ms.

Note: Callbacks, such as RebalanceCb and OffsetCommitCb, etc, may be called.

Note: The consumer object must later be freed with \c delete

class KafkaConsumer
nothrow @nogc
close
()

Meta