Topic

Topic handle

Constructors

this
this(Handle base, const(char)[] topic_str, TopicConf conf)

Creates a new topic handle for topic named \p topic_str

Destructor

~this
~this()
Undocumented in source.

Members

Functions

name
const(char)[] name()

the topic name

offsetStore
ErrorCode offsetStore(int partition, long offset)

Store offset \p offset for topic partition \p partition. The offset will be committed (written) to the offset store according to \p auto.commit.interval.ms.

partitionAvailable
bool partitionAvailable(int partition)

true if \p partition is available for the topic (has leader). Warning: \b MUST \b ONLY be called from within a PartitionerCb callback.

Static functions

partitioner_cb_trampoline
int partitioner_cb_trampoline(rd_kafka_topic_t* rkt, const(void)* keydata, size_t keylen, int partition_cnt, void* rkt_opaque, void* msg_opaque)
Undocumented in source. Be warned that the author may not have intended to support it.
partitioner_kp_cb_trampoline
int partitioner_kp_cb_trampoline(rd_kafka_topic_t* rkt, const(void)* keydata, size_t keylen, int partition_cnt, void* rkt_opaque, void* msg_opaque)
Undocumented in source. Be warned that the author may not have intended to support it.

Variables

partitioner_cb_
PartitionerCb partitioner_cb_;
Undocumented in source.
partitioner_kp_cb_
PartitionerKeyPointerCb partitioner_kp_cb_;
Undocumented in source.
rkt_
rd_kafka_topic_t* rkt_;
Undocumented in source.
unassignedPartition
enum int unassignedPartition;

Unassigned partition.

Meta