GlobalConf

Constructors

defaultTopicConf void defaultTopicConf(TopicConf topic_conf)
TopicConf defaultTopicConf(): Use with \p name = \c \"default_topic_conf\"
drCb void drCb(DeliveryReportCb cb)
dump string[string] dump(): Dump configuration names and values to list containing * name,value tuples
eventCb void eventCb(EventCb cb)
offsetCommitCb void offsetCommitCb(OffsetCommitCb cb)
opIndex string opIndex(char[] name): Query single configuration value * OK if the property was set previously set and * returns the value in \p value.
opIndexAssign void opIndexAssign(char[] value, char[] name): Set configuration property \p name to value \p value. OK on success, else writes a human readable error description to \p errstr on error.
openCb void openCb(OpenCb cb)
rebalanceCb void rebalanceCb(RebalanceCb cb)
socketCb void socketCb(SocketCb cb)

dr_cb_ DeliveryReportCb dr_cb_;: Undocumented in source.
event_cb_ EventCb event_cb_;: Undocumented in source.
offset_commit_cb_ OffsetCommitCb offset_commit_cb_;: Undocumented in source.
open_cb_ OpenCb open_cb_;: Undocumented in source.
rebalance_cb_ RebalanceCb rebalance_cb_;: Undocumented in source.
rk_conf_ rd_kafka_conf_t* rk_conf_;: Undocumented in source.
socket_cb_ SocketCb socket_cb_;: Undocumented in source.

opIndexAssign void opIndexAssign(char[] value, char[] name): Set configuration property \p name to value \p value. OK on success, else writes a human readable error description to \p errstr on error.
opIndex string opIndex(char[] name): Query single configuration value * OK if the property was set previously set and * returns the value in \p value.
dump string[string] dump()
fromText void fromText(string text)