rdkafkad.config

Members

Aliases

OpenCb

alias OpenCb = int function(const(char)[] path, int flags, int mode) nothrow @(nogc)

Open callback The open callback is responsible for opening the file specified by \p pathname, using \p flags and \p mode. The file shall be opened with \c CLOEXEC set in a racefree fashion, if possible.

Classes

Conf

class Conf

Configuration interface

ConfException

class ConfException

GlobalConf

class GlobalConf

TopicConf

class TopicConf

Undocumented in source.

• config
• handler
• metadata
• topic

• ConsumeCb
• DeliveryReportCb
• EventCb
• OffsetCommitCb
• PartitionerCb
• PartitionerKeyPointerCb
• RebalanceCb
• SocketCb

• ErrorCode

• err2str
• getDebugContexts
• versionStr
• version_
• waitDestroyed

• RD_KAFKA_VERSION

• Event
• Message