TopicConf

Undocumented in source.

class TopicConf : Conf {

void opIndexAssign(char[] value, char[] name);

string opIndex(char[] name);

string[string] dump();

package nothrow @nogc

PartitionerCb partitioner_cb_;

package nothrow @nogc

PartitionerKeyPointerCb partitioner_kp_cb_;

package nothrow @nogc

rd_kafka_topic_conf_t* rkt_conf_;

void partitionerCb(PartitionerCb cb);

void partitionerKpCb(PartitionerKeyPointerCb cb);

}

Constructors

this this(): Create configuration object

Destructor

~this ~this(): Undocumented in source.

Members

Functions

dump string[string] dump(): Dump configuration names and values to list containing * name,value tuples
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.
partitionerCb void partitionerCb(PartitionerCb cb)
partitionerKpCb void partitionerKpCb(PartitionerKeyPointerCb cb)

Variables

partitioner_cb_ PartitionerCb partitioner_cb_;: Undocumented in source.
partitioner_kp_cb_ PartitionerKeyPointerCb partitioner_kp_cb_;: Undocumented in source.
rkt_conf_ rd_kafka_topic_conf_t* rkt_conf_;: Undocumented in source.

Inherited Members

From Conf

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)

Meta

Source

See Implementation

rdkafkad config aliases

OpenCb

classes