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.
Generated on Fri Oct 11 2024 00:20:08 for librdkafka by
1.8.17