Topic

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.

• Topic

• Offset

• TopicPartition