librdkafka
The Apache Kafka C/C++ client library
 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()