Producer

Constructors

this

this(GlobalConf conf)

Creates a new Kafka producer handle.

Destructor

~this

~this()

Undocumented in source.

Members

Enums

MsgOpt

enum MsgOpt

Producer::produce() \p msgflags

Functions

flush

ErrorCode flush(int timeout_ms)

Wait until all outstanding produce requests, et.al, are completed. This should typically be done prior to destroying a producer instance to make sure all queued and in-flight produce requests are completed before terminating.

newTopic

Topic newTopic(const(char)[] topic, TopicConf topicConf)

produce

ErrorCode produce(Topic topic, int partition, void[] payload, const(void)[] key, long timestamp, int msgflags, void* msg_opaque)

Produce and send a single message to broker.

Variables

_conf

GlobalConf _conf;

Undocumented in source.

• Producer