Producer

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.

Inherited Members

From Handle

memberid
auto memberid()

Returns the client's broker-assigned group member id

metadata
Metadata metadata(bool all_topics, Topic only_rkt, int timeout_ms)

Request Metadata from broker.

setCommonConfig
void setCommonConfig(GlobalConf conf)
Undocumented in source. Be warned that the author may not have intended to support it.
queryWatermarkOffsets
auto queryWatermarkOffsets(const(char)* topic, int partition, long low, long high, int timeout_ms)

Query broker for low (oldest/beginning) and high (newest/end) offsets for partition.

rk_
rd_kafka_t* rk_;
Undocumented in source.
event_cb_
EventCb event_cb_;
Undocumented in source.
socket_cb_
SocketCb socket_cb_;
Undocumented in source.
open_cb_
OpenCb open_cb_;
Undocumented in source.
dr_cb_
DeliveryReportCb dr_cb_;
Undocumented in source.
partitioner_cb_
PartitionerCb partitioner_cb_;
Undocumented in source.
partitioner_kp_cb_
PartitionerKeyPointerCb partitioner_kp_cb_;
Undocumented in source.
rebalance_cb_
RebalanceCb rebalance_cb_;
Undocumented in source.
offset_commit_cb_
OffsetCommitCb offset_commit_cb_;
Undocumented in source.
name
const(char)[] name()

the name of the handle

poll
int poll(int timeout_ms)

Polls the provided kafka handle for events.

outqLen
int outqLen()

Returns the current out queue length

free_partition_vector
void free_partition_vector(TopicPartition[] v)
Undocumented in source. Be warned that the author may not have intended to support it.
pause
ErrorCode pause(TopicPartition[] partitions)

Pause producing or consumption for the provided list of partitions.

resume
ErrorCode resume(TopicPartition[] partitions)

Resume producing or consumption for the provided list of partitions.

getWatermarkOffsets
ErrorCode getWatermarkOffsets(const(char)* topic, int partition, long low, long high)

Get last known low (oldest/beginning) and high (newest/end) offsets for partition.

Meta