Handle

Base handle, super class for specific clients.

Members

Functions

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.

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.

name
const(char)[] name()

the name of the handle

outqLen
int outqLen()

Returns the current out queue length

pause
ErrorCode pause(TopicPartition[] partitions)

Pause producing or consumption for the provided list of partitions.

poll
int poll(int timeout_ms)

Polls the provided kafka handle for events.

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.

resume
ErrorCode resume(TopicPartition[] partitions)

Resume producing or consumption for the provided list of partitions.

setCommonConfig
void setCommonConfig(GlobalConf conf)
Undocumented in source. Be warned that the author may not have intended to support it.

Static functions

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

Variables

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.
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.
rk_
rd_kafka_t* rk_;
Undocumented in source.
socket_cb_
SocketCb socket_cb_;
Undocumented in source.

Meta