Here is a list of all documented functions, variables, defines, enums, and typedefs with links to the documentation:

- r -

• rd_kafka_assign() : rdkafka.h
• rd_kafka_assignment() : rdkafka.h
• rd_kafka_brokers_add() : rdkafka.h
• rd_kafka_clusterid() : rdkafka.h
• rd_kafka_commit() : rdkafka.h
• rd_kafka_commit_message() : rdkafka.h
• rd_kafka_commit_queue() : rdkafka.h
• rd_kafka_committed() : rdkafka.h
• rd_kafka_conf_destroy() : rdkafka.h
• rd_kafka_conf_dump() : rdkafka.h
• rd_kafka_conf_dump_free() : rdkafka.h
• rd_kafka_conf_dup() : rdkafka.h
• rd_kafka_conf_dup_filter() : rdkafka.h
• rd_kafka_conf_get() : rdkafka.h
• rd_kafka_conf_interceptor_add_on_conf_destroy() : rdkafka.h
• rd_kafka_conf_interceptor_add_on_conf_dup() : rdkafka.h
• rd_kafka_conf_interceptor_add_on_conf_set() : rdkafka.h
• rd_kafka_conf_interceptor_add_on_new() : rdkafka.h
• RD_KAFKA_CONF_INVALID : rdkafka.h
• rd_kafka_conf_new() : rdkafka.h
• RD_KAFKA_CONF_OK : rdkafka.h
• rd_kafka_conf_properties_show() : rdkafka.h
• rd_kafka_conf_res_t : rdkafka.h
• rd_kafka_conf_set() : rdkafka.h
• rd_kafka_conf_set_closesocket_cb() : rdkafka.h
• rd_kafka_conf_set_connect_cb() : rdkafka.h
• rd_kafka_conf_set_consume_cb() : rdkafka.h
• rd_kafka_conf_set_default_topic_conf() : rdkafka.h
• rd_kafka_conf_set_dr_cb() : rdkafka.h
• rd_kafka_conf_set_dr_msg_cb() : rdkafka.h
• rd_kafka_conf_set_error_cb() : rdkafka.h
• rd_kafka_conf_set_events() : rdkafka.h
• rd_kafka_conf_set_log_cb() : rdkafka.h
• rd_kafka_conf_set_offset_commit_cb() : rdkafka.h
• rd_kafka_conf_set_opaque() : rdkafka.h
• rd_kafka_conf_set_open_cb() : rdkafka.h
• rd_kafka_conf_set_rebalance_cb() : rdkafka.h
• rd_kafka_conf_set_socket_cb() : rdkafka.h
• rd_kafka_conf_set_stats_cb() : rdkafka.h
• rd_kafka_conf_set_throttle_cb() : rdkafka.h
• RD_KAFKA_CONF_UNKNOWN : rdkafka.h
• rd_kafka_consume() : rdkafka.h
• rd_kafka_consume_batch() : rdkafka.h
• rd_kafka_consume_batch_queue() : rdkafka.h
• rd_kafka_consume_callback() : rdkafka.h
• rd_kafka_consume_callback_queue() : rdkafka.h
• rd_kafka_consume_queue() : rdkafka.h
• rd_kafka_consume_start() : rdkafka.h
• rd_kafka_consume_start_queue() : rdkafka.h
• rd_kafka_consume_stop() : rdkafka.h
• RD_KAFKA_CONSUMER : rdkafka.h
• rd_kafka_consumer_close() : rdkafka.h
• rd_kafka_consumer_poll() : rdkafka.h
• RD_KAFKA_DEBUG_CONTEXTS : rdkafka.h
• rd_kafka_default_topic_conf_dup() : rdkafka.h
• rd_kafka_destroy() : rdkafka.h
• rd_kafka_dump() : rdkafka.h
• rd_kafka_err2name() : rdkafka.h
• rd_kafka_err2str() : rdkafka.h
• rd_kafka_errno() : rdkafka.h
• rd_kafka_errno2err() : rdkafka.h
• rd_kafka_event_destroy() : rdkafka.h
• RD_KAFKA_EVENT_DR : rdkafka.h
• rd_kafka_event_error() : rdkafka.h
• RD_KAFKA_EVENT_ERROR : rdkafka.h
• rd_kafka_event_error_string() : rdkafka.h
• RD_KAFKA_EVENT_FETCH : rdkafka.h
• RD_KAFKA_EVENT_LOG : rdkafka.h
• rd_kafka_event_log() : rdkafka.h
• rd_kafka_event_message_array() : rdkafka.h
• rd_kafka_event_message_count() : rdkafka.h
• rd_kafka_event_message_next() : rdkafka.h
• rd_kafka_event_name() : rdkafka.h
• RD_KAFKA_EVENT_OFFSET_COMMIT : rdkafka.h
• rd_kafka_event_opaque() : rdkafka.h
• RD_KAFKA_EVENT_REBALANCE : rdkafka.h
• rd_kafka_event_stats() : rdkafka.h
• RD_KAFKA_EVENT_STATS : rdkafka.h
• rd_kafka_event_topic_partition() : rdkafka.h
• rd_kafka_event_topic_partition_list() : rdkafka.h
• rd_kafka_event_type() : rdkafka.h
• rd_kafka_event_type_t : rdkafka.h
• rd_kafka_flush() : rdkafka.h
• rd_kafka_get_debug_contexts() : rdkafka.h
• rd_kafka_get_err_descs() : rdkafka.h
• rd_kafka_get_watermark_offsets() : rdkafka.h
• rd_kafka_group_list_destroy() : rdkafka.h
• rd_kafka_header_add() : rdkafka.h
• rd_kafka_header_cnt() : rdkafka.h
• rd_kafka_header_get() : rdkafka.h
• rd_kafka_header_get_all() : rdkafka.h
• rd_kafka_header_get_last() : rdkafka.h
• rd_kafka_header_remove() : rdkafka.h
• rd_kafka_headers_copy() : rdkafka.h
• rd_kafka_headers_destroy() : rdkafka.h
• rd_kafka_headers_new() : rdkafka.h
• rd_kafka_interceptor_add_on_acknowledgement() : rdkafka.h
• rd_kafka_interceptor_add_on_commit() : rdkafka.h
• rd_kafka_interceptor_add_on_consume() : rdkafka.h
• rd_kafka_interceptor_add_on_destroy() : rdkafka.h
• rd_kafka_interceptor_add_on_request_sent() : rdkafka.h
• rd_kafka_interceptor_add_on_send() : rdkafka.h
• rd_kafka_interceptor_f_on_acknowledgement_t : rdkafka.h
• rd_kafka_interceptor_f_on_commit_t : rdkafka.h
• rd_kafka_interceptor_f_on_conf_destroy_t : rdkafka.h
• rd_kafka_interceptor_f_on_conf_dup_t : rdkafka.h
• rd_kafka_interceptor_f_on_conf_set_t : rdkafka.h
• rd_kafka_interceptor_f_on_consume_t : rdkafka.h
• rd_kafka_interceptor_f_on_destroy_t : rdkafka.h
• rd_kafka_interceptor_f_on_new_t : rdkafka.h
• rd_kafka_interceptor_f_on_request_sent_t : rdkafka.h
• rd_kafka_interceptor_f_on_send_t : rdkafka.h
• rd_kafka_last_error() : rdkafka.h
• rd_kafka_list_groups() : rdkafka.h
• rd_kafka_log_print() : rdkafka.h
• rd_kafka_log_syslog() : rdkafka.h
• rd_kafka_mem_free() : rdkafka.h
• rd_kafka_memberid() : rdkafka.h
• rd_kafka_message_destroy() : rdkafka.h
• rd_kafka_message_detach_headers() : rdkafka.h
• rd_kafka_message_errstr() : rdkafka.h
• rd_kafka_message_headers() : rdkafka.h
• rd_kafka_message_latency() : rdkafka.h
• rd_kafka_message_set_headers() : rdkafka.h
• rd_kafka_message_timestamp() : rdkafka.h
• rd_kafka_metadata() : rdkafka.h
• rd_kafka_metadata_destroy() : rdkafka.h
• RD_KAFKA_MSG_F_BLOCK : rdkafka.h
• RD_KAFKA_MSG_F_COPY : rdkafka.h
• RD_KAFKA_MSG_F_FREE : rdkafka.h
• RD_KAFKA_MSG_F_PARTITION : rdkafka.h
• rd_kafka_msg_partitioner_consistent() : rdkafka.h
• rd_kafka_msg_partitioner_consistent_random() : rdkafka.h
• rd_kafka_msg_partitioner_murmur2() : rdkafka.h
• rd_kafka_msg_partitioner_murmur2_random() : rdkafka.h
• rd_kafka_msg_partitioner_random() : rdkafka.h
• rd_kafka_name() : rdkafka.h
• rd_kafka_new() : rdkafka.h
• RD_KAFKA_OFFSET_BEGINNING : rdkafka.h
• RD_KAFKA_OFFSET_END : rdkafka.h
• RD_KAFKA_OFFSET_INVALID : rdkafka.h
• rd_kafka_offset_store() : rdkafka.h
• RD_KAFKA_OFFSET_STORED : rdkafka.h
• RD_KAFKA_OFFSET_TAIL : rdkafka.h
• rd_kafka_offsets_for_times() : rdkafka.h
• rd_kafka_offsets_store() : rdkafka.h
• rd_kafka_opaque() : rdkafka.h
• rd_kafka_outq_len() : rdkafka.h
• RD_KAFKA_PARTITION_UA : rdkafka.h
• rd_kafka_pause_partitions() : rdkafka.h
• rd_kafka_plugin_f_conf_init_t : rdkafka.h
• rd_kafka_poll() : rdkafka.h
• rd_kafka_poll_set_consumer() : rdkafka.h
• rd_kafka_position() : rdkafka.h
• rd_kafka_produce() : rdkafka.h
• rd_kafka_produce_batch() : rdkafka.h
• RD_KAFKA_PRODUCER : rdkafka.h
• rd_kafka_producev() : rdkafka.h
• rd_kafka_query_watermark_offsets() : rdkafka.h
• rd_kafka_queue_destroy() : rdkafka.h
• rd_kafka_queue_forward() : rdkafka.h
• rd_kafka_queue_get_consumer() : rdkafka.h
• rd_kafka_queue_get_main() : rdkafka.h
• rd_kafka_queue_get_partition() : rdkafka.h
• rd_kafka_queue_io_event_enable() : rdkafka.h
• rd_kafka_queue_length() : rdkafka.h
• rd_kafka_queue_new() : rdkafka.h
• rd_kafka_queue_poll() : rdkafka.h
• rd_kafka_queue_poll_callback() : rdkafka.h
• RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN : rdkafka.h
• RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS : rdkafka.h
• RD_KAFKA_RESP_ERR__AUTHENTICATION : rdkafka.h
• RD_KAFKA_RESP_ERR__BAD_COMPRESSION : rdkafka.h
• RD_KAFKA_RESP_ERR__BAD_MSG : rdkafka.h
• RD_KAFKA_RESP_ERR__BEGIN : rdkafka.h
• RD_KAFKA_RESP_ERR__CONFLICT : rdkafka.h
• RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE : rdkafka.h
• RD_KAFKA_RESP_ERR__DESTROY : rdkafka.h
• RD_KAFKA_RESP_ERR__END : rdkafka.h
• RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION : rdkafka.h
• RD_KAFKA_RESP_ERR__FAIL : rdkafka.h
• RD_KAFKA_RESP_ERR__FS : rdkafka.h
• RD_KAFKA_RESP_ERR__IN_PROGRESS : rdkafka.h
• RD_KAFKA_RESP_ERR__INTR : rdkafka.h
• RD_KAFKA_RESP_ERR__INVALID_ARG : rdkafka.h
• RD_KAFKA_RESP_ERR__ISR_INSUFF : rdkafka.h
• RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION : rdkafka.h
• RD_KAFKA_RESP_ERR__KEY_SERIALIZATION : rdkafka.h
• RD_KAFKA_RESP_ERR__MSG_TIMED_OUT : rdkafka.h
• RD_KAFKA_RESP_ERR__NO_OFFSET : rdkafka.h
• RD_KAFKA_RESP_ERR__NODE_UPDATE : rdkafka.h
• RD_KAFKA_RESP_ERR__NOENT : rdkafka.h
• RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED : rdkafka.h
• RD_KAFKA_RESP_ERR__OUTDATED : rdkafka.h
• RD_KAFKA_RESP_ERR__PARTIAL : rdkafka.h
• RD_KAFKA_RESP_ERR__PARTITION_EOF : rdkafka.h
• RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS : rdkafka.h
• RD_KAFKA_RESP_ERR__QUEUE_FULL : rdkafka.h
• RD_KAFKA_RESP_ERR__READ_ONLY : rdkafka.h
• RD_KAFKA_RESP_ERR__RESOLVE : rdkafka.h
• RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS : rdkafka.h
• RD_KAFKA_RESP_ERR__SSL : rdkafka.h
• RD_KAFKA_RESP_ERR__STATE : rdkafka.h
• RD_KAFKA_RESP_ERR__TIMED_OUT : rdkafka.h
• RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE : rdkafka.h
• RD_KAFKA_RESP_ERR__TRANSPORT : rdkafka.h
• RD_KAFKA_RESP_ERR__UNDERFLOW : rdkafka.h
• RD_KAFKA_RESP_ERR__UNKNOWN_GROUP : rdkafka.h
• RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION : rdkafka.h
• RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL : rdkafka.h
• RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC : rdkafka.h
• RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE : rdkafka.h
• RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION : rdkafka.h
• RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION : rdkafka.h
• RD_KAFKA_RESP_ERR__WAIT_CACHE : rdkafka.h
• RD_KAFKA_RESP_ERR__WAIT_COORD : rdkafka.h
• RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE : rdkafka.h
• RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED : rdkafka.h
• RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS : rdkafka.h
• RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER : rdkafka.h
• RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED : rdkafka.h
• RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE : rdkafka.h
• RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS : rdkafka.h
• RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION : rdkafka.h
• RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE : rdkafka.h
• RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_CONFIG : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_GROUP_ID : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_MSG : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_PARTITIONS : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_REQUEST : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT : rdkafka.h
• RD_KAFKA_RESP_ERR_INVALID_TXN_STATE : rdkafka.h
• RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE : rdkafka.h
• RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE : rdkafka.h
• RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION : rdkafka.h
• RD_KAFKA_RESP_ERR_NO_ERROR : rdkafka.h
• RD_KAFKA_RESP_ERR_NOT_CONTROLLER : rdkafka.h
• RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP : rdkafka.h
• RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS : rdkafka.h
• RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND : rdkafka.h
• RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION : rdkafka.h
• RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE : rdkafka.h
• RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE : rdkafka.h
• RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED : rdkafka.h
• RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER : rdkafka.h
• RD_KAFKA_RESP_ERR_POLICY_VIOLATION : rdkafka.h
• RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS : rdkafka.h
• RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE : rdkafka.h
• RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE : rdkafka.h
• RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT : rdkafka.h
• RD_KAFKA_RESP_ERR_SECURITY_DISABLED : rdkafka.h
• RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH : rdkafka.h
• rd_kafka_resp_err_t : rdkafka.h
• RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS : rdkafka.h
• RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED : rdkafka.h
• RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION : rdkafka.h
• RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED : rdkafka.h
• RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED : rdkafka.h
• RD_KAFKA_RESP_ERR_UNKNOWN : rdkafka.h
• RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID : rdkafka.h
• RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART : rdkafka.h
• RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT : rdkafka.h
• RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM : rdkafka.h
• RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION : rdkafka.h
• rd_kafka_resume_partitions() : rdkafka.h
• rd_kafka_seek() : rdkafka.h
• rd_kafka_set_log_level() : rdkafka.h
• rd_kafka_set_log_queue() : rdkafka.h
• rd_kafka_set_logger() : rdkafka.h
• rd_kafka_subscribe() : rdkafka.h
• rd_kafka_subscription() : rdkafka.h
• rd_kafka_thread_cnt() : rdkafka.h
• RD_KAFKA_TIMESTAMP_CREATE_TIME : rdkafka.h
• RD_KAFKA_TIMESTAMP_LOG_APPEND_TIME : rdkafka.h
• RD_KAFKA_TIMESTAMP_NOT_AVAILABLE : rdkafka.h
• rd_kafka_timestamp_type_t : rdkafka.h
• rd_kafka_topic_conf_destroy() : rdkafka.h
• rd_kafka_topic_conf_dump() : rdkafka.h
• rd_kafka_topic_conf_dup() : rdkafka.h
• rd_kafka_topic_conf_get() : rdkafka.h
• rd_kafka_topic_conf_new() : rdkafka.h
• rd_kafka_topic_conf_set() : rdkafka.h
• rd_kafka_topic_conf_set_msg_order_cmp() : rdkafka.h
• rd_kafka_topic_conf_set_opaque() : rdkafka.h
• rd_kafka_topic_conf_set_partitioner_cb() : rdkafka.h
• rd_kafka_topic_destroy() : rdkafka.h
• rd_kafka_topic_name() : rdkafka.h
• rd_kafka_topic_new() : rdkafka.h
• rd_kafka_topic_opaque() : rdkafka.h
• rd_kafka_topic_partition_available() : rdkafka.h
• rd_kafka_topic_partition_destroy() : rdkafka.h
• rd_kafka_topic_partition_list_add() : rdkafka.h
• rd_kafka_topic_partition_list_add_range() : rdkafka.h
• rd_kafka_topic_partition_list_copy() : rdkafka.h
• rd_kafka_topic_partition_list_del() : rdkafka.h
• rd_kafka_topic_partition_list_del_by_idx() : rdkafka.h
• rd_kafka_topic_partition_list_destroy() : rdkafka.h
• rd_kafka_topic_partition_list_find() : rdkafka.h
• rd_kafka_topic_partition_list_new() : rdkafka.h
• rd_kafka_topic_partition_list_set_offset() : rdkafka.h
• rd_kafka_topic_partition_list_sort() : rdkafka.h
• rd_kafka_type() : rdkafka.h
• rd_kafka_type_t : rdkafka.h
• rd_kafka_unittest() : rdkafka.h
• rd_kafka_unsubscribe() : rdkafka.h
• RD_KAFKA_V_END : rdkafka.h
• RD_KAFKA_V_HEADER : rdkafka.h
• RD_KAFKA_V_HEADERS : rdkafka.h
• RD_KAFKA_V_KEY : rdkafka.h
• RD_KAFKA_V_MSGFLAGS : rdkafka.h
• RD_KAFKA_V_OPAQUE : rdkafka.h
• RD_KAFKA_V_PARTITION : rdkafka.h
• RD_KAFKA_V_RKT : rdkafka.h
• RD_KAFKA_V_TIMESTAMP : rdkafka.h
• RD_KAFKA_V_TOPIC : rdkafka.h
• RD_KAFKA_V_VALUE : rdkafka.h
• RD_KAFKA_VERSION : rdkafka.h
• rd_kafka_version() : rdkafka.h
• RD_KAFKA_VERSION : rdkafkacpp.h
• rd_kafka_version_str() : rdkafka.h
• RD_KAFKA_VTYPE_END : rdkafka.h
• RD_KAFKA_VTYPE_HEADER : rdkafka.h
• RD_KAFKA_VTYPE_HEADERS : rdkafka.h
• RD_KAFKA_VTYPE_KEY : rdkafka.h
• RD_KAFKA_VTYPE_MSGFLAGS : rdkafka.h
• RD_KAFKA_VTYPE_OPAQUE : rdkafka.h
• RD_KAFKA_VTYPE_PARTITION : rdkafka.h
• RD_KAFKA_VTYPE_RKT : rdkafka.h
• rd_kafka_vtype_t : rdkafka.h
• RD_KAFKA_VTYPE_TIMESTAMP : rdkafka.h
• RD_KAFKA_VTYPE_TOPIC : rdkafka.h
• RD_KAFKA_VTYPE_VALUE : rdkafka.h
• rd_kafka_wait_destroyed() : rdkafka.h
• rd_kafka_yield() : rdkafka.h