librdkafka
The Apache Kafka C/C++ client library
Deprecated List
Global rd_kafka_AlterConfigs (rd_kafka_t *rk, rd_kafka_ConfigResource_t **configs, size_t config_cnt, const rd_kafka_AdminOptions_t *options, rd_kafka_queue_t *rkqu)
Use rd_kafka_IncrementalAlterConfigs().
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_list_groups (rd_kafka_t *rk, const char *group, const struct rd_kafka_group_list **grplistp, int timeout_ms)
Use rd_kafka_ListConsumerGroups() and rd_kafka_DescribeConsumerGroups() instead.
Global rd_kafka_offset_store (rd_kafka_topic_t *rkt, int32_t partition, int64_t offset)
This API lacks support for partition leader epochs, which makes it at risk for unclean leader election log truncation issues. Use rd_kafka_offsets_store() and rd_kafka_offset_store_message() instead.
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()
Global RdKafka::Topic::offset_store (int32_t partition, int64_t offset)=0
This API lacks support for partition leader epochs, which makes it at risk for unclean leader election log truncation issues. Use KafkaConsumer::offsets_store() or Message::offset_store() instead.