- 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()
- 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.
Base handle, super class for specific clients.