librdkafka
The Apache Kafka C/C++ client library
Main Page
Related Pages
Data Structures
Files
All
Data Structures
Files
Functions
Variables
Typedefs
Enumerations
Enumerator
Macros
Pages
Deprecated List
Global
rd_kafka_brokers_add
(rd_kafka_t *rk, const char *brokerlist)
Set bootstrap servers with the
bootstrap.servers
configuration property.
Global
rd_kafka_conf_set_default_topic_conf
(rd_kafka_conf_t *conf, rd_kafka_topic_conf_t *tconf)
Set default topic level configuration on the global rd_kafka_conf_t object instead.
Global
rd_kafka_conf_set_dr_cb
(rd_kafka_conf_t *conf, void(*dr_cb)(rd_kafka_t *rk, void *payload, size_t len, rd_kafka_resp_err_t err, void *opaque, void *msg_opaque))
See
rd_kafka_conf_set_dr_msg_cb()
Global
rd_kafka_consume_callback
(rd_kafka_topic_t *rkt, int32_t partition, int timeout_ms, void(*consume_cb)(
rd_kafka_message_t
*rkmessage, void *commit_opaque), void *commit_opaque)
This API is deprecated and subject for future removal. There is no new callback-based consume interface, use the poll/queue based alternatives.
Global
rd_kafka_consume_callback_queue
(rd_kafka_queue_t *rkqu, int timeout_ms, void(*consume_cb)(
rd_kafka_message_t
*rkmessage, void *commit_opaque), void *commit_opaque)
This API is deprecated and subject for future removal. There is no new callback-based consume interface, use the poll/queue based alternatives.
Global
RD_KAFKA_DEBUG_CONTEXTS
This compile time value may be outdated at runtime due to linking another version of the library. Use
rd_kafka_get_debug_contexts()
instead.
Global
rd_kafka_errno
(void)
Use
rd_kafka_last_error()
to retrieve the last error code set by the legacy librdkafka APIs.
Global
rd_kafka_errno2err
(int errnox)
Use
rd_kafka_last_error()
to retrieve the last error code set by the legacy librdkafka APIs.
Global
rd_kafka_seek
(rd_kafka_topic_t *rkt, int32_t partition, int64_t offset, int timeout_ms)
Use
rd_kafka_seek_partitions()
.
Global
rd_kafka_set_log_level
(rd_kafka_t *rk, int level)
Set the
"log_level"
configuration property instead.
Global
rd_kafka_set_logger
(rd_kafka_t *rk, void(*func)(const rd_kafka_t *rk, int level, const char *fac, const char *buf))
Use
rd_kafka_conf_set_log_cb()
Generated on Fri Apr 21 2023 16:28:29 for librdkafka by
1.8.8