Topic handle.
More...
#include <rdkafkacpp.h>
|
virtual const std::string | name () const =0 |
|
virtual bool | partition_available (int32_t partition) const =0 |
|
virtual ErrorCode | offset_store (int32_t partition, int64_t offset)=0 |
| Store offset offset for topic partition partition . The offset will be committed (written) to the offset store according to auto.commit.interval.ms . More...
|
|
|
static Topic * | create (Handle *base, const std::string &topic_str, Conf *conf, std::string &errstr) |
| Creates a new topic handle for topic named topic_str . More...
|
|
◆ create()
static Topic* RdKafka::Topic::create |
( |
Handle * |
base, |
|
|
const std::string & |
topic_str, |
|
|
Conf * |
conf, |
|
|
std::string & |
errstr |
|
) |
| |
|
static |
Creates a new topic handle for topic named topic_str
.
conf
is an optional configuration for the topic that will be used instead of the default topic configuration. The conf
object is reusable after this call.
- Returns
- the new topic handle or NULL on error (see
errstr
).
◆ name()
virtual const std::string RdKafka::Topic::name |
( |
| ) |
const |
|
pure virtual |
◆ partition_available()
virtual bool RdKafka::Topic::partition_available |
( |
int32_t |
partition | ) |
const |
|
pure virtual |
- Returns
- true if
partition
is available for the topic (has leader).
- Warning
- MUST ONLY be called from within a RdKafka::PartitionerCb callback.
◆ offset_store()
virtual ErrorCode RdKafka::Topic::offset_store |
( |
int32_t |
partition, |
|
|
int64_t |
offset |
|
) |
| |
|
pure virtual |
Store offset offset
for topic partition partition
. The offset will be committed (written) to the offset store according to auto.commit.interval.ms
.
- Returns
- RdKafka::ERR_NO_ERROR on success or an error code on error.
◆ PARTITION_UA
const int32_t RdKafka::Topic::PARTITION_UA = -1 |
|
static |
Unassigned partition.
The unassigned partition is used by the producer API for messages that should be partitioned using the configured or default partitioner.
◆ OFFSET_BEGINNING
const int64_t RdKafka::Topic::OFFSET_BEGINNING = -2 |
|
static |
Special offsets.
Consume from beginning
◆ OFFSET_END
const int64_t RdKafka::Topic::OFFSET_END = -1 |
|
static |
◆ OFFSET_STORED
const int64_t RdKafka::Topic::OFFSET_STORED = -1000 |
|
static |
◆ OFFSET_INVALID
const int64_t RdKafka::Topic::OFFSET_INVALID = -1001 |
|
static |
The documentation for this class was generated from the following file: