List of all items
Structs
- bindings::__BindgenUnionField
- bindings::rd_kafka_AdminOptions_s
- bindings::rd_kafka_ConfigEntry_s
- bindings::rd_kafka_ConfigResource_s
- bindings::rd_kafka_DeleteConsumerGroupOffsets_s
- bindings::rd_kafka_DeleteGroup_s
- bindings::rd_kafka_DeleteRecords_s
- bindings::rd_kafka_DeleteTopic_s
- bindings::rd_kafka_NewPartitions_s
- bindings::rd_kafka_NewTopic_s
- bindings::rd_kafka_conf_s
- bindings::rd_kafka_consumer_group_metadata_s
- bindings::rd_kafka_err_desc
- bindings::rd_kafka_error_s
- bindings::rd_kafka_group_info
- bindings::rd_kafka_group_list
- bindings::rd_kafka_group_member_info
- bindings::rd_kafka_group_result_s
- bindings::rd_kafka_headers_s
- bindings::rd_kafka_message_s
- bindings::rd_kafka_metadata
- bindings::rd_kafka_metadata_broker
- bindings::rd_kafka_metadata_partition
- bindings::rd_kafka_metadata_topic
- bindings::rd_kafka_op_s
- bindings::rd_kafka_queue_s
- bindings::rd_kafka_s
- bindings::rd_kafka_topic_conf_s
- bindings::rd_kafka_topic_partition_list_s
- bindings::rd_kafka_topic_partition_s
- bindings::rd_kafka_topic_result_s
- bindings::rd_kafka_topic_s
- bindings::rd_kafka_vu_s
- bindings::rd_kafka_vu_s__bindgen_ty_1
- bindings::rd_kafka_vu_s__bindgen_ty_1__bindgen_ty_1
- bindings::rd_kafka_vu_s__bindgen_ty_1__bindgen_ty_2
Enums
- bindings::rd_kafka_ConfigSource_t
- bindings::rd_kafka_ResourceType_t
- bindings::rd_kafka_admin_op_t
- bindings::rd_kafka_cert_enc_t
- bindings::rd_kafka_cert_type_t
- bindings::rd_kafka_conf_res_t
- bindings::rd_kafka_msg_status_t
- bindings::rd_kafka_resp_err_t
- bindings::rd_kafka_thread_type_t
- bindings::rd_kafka_timestamp_type_t
- bindings::rd_kafka_type_t
- bindings::rd_kafka_vtype_t
- types::RDKafkaErrorCode
Functions
- bindings::rd_kafka_AdminOptions_destroy
- bindings::rd_kafka_AdminOptions_new
- bindings::rd_kafka_AdminOptions_set_broker
- bindings::rd_kafka_AdminOptions_set_opaque
- bindings::rd_kafka_AdminOptions_set_operation_timeout
- bindings::rd_kafka_AdminOptions_set_request_timeout
- bindings::rd_kafka_AdminOptions_set_validate_only
- bindings::rd_kafka_AlterConfigs
- bindings::rd_kafka_AlterConfigs_result_resources
- bindings::rd_kafka_ConfigEntry_is_default
- bindings::rd_kafka_ConfigEntry_is_read_only
- bindings::rd_kafka_ConfigEntry_is_sensitive
- bindings::rd_kafka_ConfigEntry_is_synonym
- bindings::rd_kafka_ConfigEntry_name
- bindings::rd_kafka_ConfigEntry_source
- bindings::rd_kafka_ConfigEntry_synonyms
- bindings::rd_kafka_ConfigEntry_value
- bindings::rd_kafka_ConfigResource_configs
- bindings::rd_kafka_ConfigResource_destroy
- bindings::rd_kafka_ConfigResource_destroy_array
- bindings::rd_kafka_ConfigResource_error
- bindings::rd_kafka_ConfigResource_error_string
- bindings::rd_kafka_ConfigResource_name
- bindings::rd_kafka_ConfigResource_new
- bindings::rd_kafka_ConfigResource_set_config
- bindings::rd_kafka_ConfigResource_type
- bindings::rd_kafka_ConfigSource_name
- bindings::rd_kafka_CreatePartitions
- bindings::rd_kafka_CreatePartitions_result_topics
- bindings::rd_kafka_CreateTopics
- bindings::rd_kafka_CreateTopics_result_topics
- bindings::rd_kafka_DeleteConsumerGroupOffsets
- bindings::rd_kafka_DeleteConsumerGroupOffsets_destroy
- bindings::rd_kafka_DeleteConsumerGroupOffsets_destroy_array
- bindings::rd_kafka_DeleteConsumerGroupOffsets_new
- bindings::rd_kafka_DeleteConsumerGroupOffsets_result_groups
- bindings::rd_kafka_DeleteGroup_destroy
- bindings::rd_kafka_DeleteGroup_destroy_array
- bindings::rd_kafka_DeleteGroup_new
- bindings::rd_kafka_DeleteGroups
- bindings::rd_kafka_DeleteGroups_result_groups
- bindings::rd_kafka_DeleteRecords
- bindings::rd_kafka_DeleteRecords_destroy
- bindings::rd_kafka_DeleteRecords_destroy_array
- bindings::rd_kafka_DeleteRecords_new
- bindings::rd_kafka_DeleteRecords_result_offsets
- bindings::rd_kafka_DeleteTopic_destroy
- bindings::rd_kafka_DeleteTopic_destroy_array
- bindings::rd_kafka_DeleteTopic_new
- bindings::rd_kafka_DeleteTopics
- bindings::rd_kafka_DeleteTopics_result_topics
- bindings::rd_kafka_DescribeConfigs
- bindings::rd_kafka_DescribeConfigs_result_resources
- bindings::rd_kafka_NewPartitions_destroy
- bindings::rd_kafka_NewPartitions_destroy_array
- bindings::rd_kafka_NewPartitions_new
- bindings::rd_kafka_NewPartitions_set_replica_assignment
- bindings::rd_kafka_NewTopic_destroy
- bindings::rd_kafka_NewTopic_destroy_array
- bindings::rd_kafka_NewTopic_new
- bindings::rd_kafka_NewTopic_set_config
- bindings::rd_kafka_NewTopic_set_replica_assignment
- bindings::rd_kafka_ResourceType_name
- bindings::rd_kafka_abort_transaction
- bindings::rd_kafka_assign
- bindings::rd_kafka_assignment
- bindings::rd_kafka_assignment_lost
- bindings::rd_kafka_begin_transaction
- bindings::rd_kafka_brokers_add
- bindings::rd_kafka_clusterid
- bindings::rd_kafka_commit
- bindings::rd_kafka_commit_message
- bindings::rd_kafka_commit_queue
- bindings::rd_kafka_commit_transaction
- bindings::rd_kafka_committed
- bindings::rd_kafka_conf
- bindings::rd_kafka_conf_destroy
- bindings::rd_kafka_conf_dump
- bindings::rd_kafka_conf_dump_free
- bindings::rd_kafka_conf_dup
- bindings::rd_kafka_conf_dup_filter
- bindings::rd_kafka_conf_get
- bindings::rd_kafka_conf_get_default_topic_conf
- bindings::rd_kafka_conf_interceptor_add_on_conf_destroy
- bindings::rd_kafka_conf_interceptor_add_on_conf_dup
- bindings::rd_kafka_conf_interceptor_add_on_conf_set
- bindings::rd_kafka_conf_interceptor_add_on_new
- bindings::rd_kafka_conf_new
- bindings::rd_kafka_conf_properties_show
- bindings::rd_kafka_conf_set
- bindings::rd_kafka_conf_set_background_event_cb
- bindings::rd_kafka_conf_set_closesocket_cb
- bindings::rd_kafka_conf_set_connect_cb
- bindings::rd_kafka_conf_set_consume_cb
- bindings::rd_kafka_conf_set_default_topic_conf
- bindings::rd_kafka_conf_set_dr_cb
- bindings::rd_kafka_conf_set_dr_msg_cb
- bindings::rd_kafka_conf_set_engine_callback_data
- bindings::rd_kafka_conf_set_error_cb
- bindings::rd_kafka_conf_set_events
- bindings::rd_kafka_conf_set_log_cb
- bindings::rd_kafka_conf_set_oauthbearer_token_refresh_cb
- bindings::rd_kafka_conf_set_offset_commit_cb
- bindings::rd_kafka_conf_set_opaque
- bindings::rd_kafka_conf_set_rebalance_cb
- bindings::rd_kafka_conf_set_socket_cb
- bindings::rd_kafka_conf_set_ssl_cert
- bindings::rd_kafka_conf_set_ssl_cert_verify_cb
- bindings::rd_kafka_conf_set_stats_cb
- bindings::rd_kafka_conf_set_throttle_cb
- bindings::rd_kafka_consume
- bindings::rd_kafka_consume_batch
- bindings::rd_kafka_consume_batch_queue
- bindings::rd_kafka_consume_callback
- bindings::rd_kafka_consume_callback_queue
- bindings::rd_kafka_consume_queue
- bindings::rd_kafka_consume_start
- bindings::rd_kafka_consume_start_queue
- bindings::rd_kafka_consume_stop
- bindings::rd_kafka_consumer_close
- bindings::rd_kafka_consumer_group_metadata
- bindings::rd_kafka_consumer_group_metadata_destroy
- bindings::rd_kafka_consumer_group_metadata_new
- bindings::rd_kafka_consumer_group_metadata_new_with_genid
- bindings::rd_kafka_consumer_group_metadata_read
- bindings::rd_kafka_consumer_group_metadata_write
- bindings::rd_kafka_consumer_poll
- bindings::rd_kafka_controllerid
- bindings::rd_kafka_default_topic_conf_dup
- bindings::rd_kafka_destroy
- bindings::rd_kafka_destroy_flags
- bindings::rd_kafka_dump
- bindings::rd_kafka_err2name
- bindings::rd_kafka_err2str
- bindings::rd_kafka_errno
- bindings::rd_kafka_errno2err
- bindings::rd_kafka_error_code
- bindings::rd_kafka_error_destroy
- bindings::rd_kafka_error_is_fatal
- bindings::rd_kafka_error_is_retriable
- bindings::rd_kafka_error_name
- bindings::rd_kafka_error_new
- bindings::rd_kafka_error_string
- bindings::rd_kafka_error_txn_requires_abort
- bindings::rd_kafka_event_AlterConfigs_result
- bindings::rd_kafka_event_CreatePartitions_result
- bindings::rd_kafka_event_CreateTopics_result
- bindings::rd_kafka_event_DeleteConsumerGroupOffsets_result
- bindings::rd_kafka_event_DeleteGroups_result
- bindings::rd_kafka_event_DeleteRecords_result
- bindings::rd_kafka_event_DeleteTopics_result
- bindings::rd_kafka_event_DescribeConfigs_result
- bindings::rd_kafka_event_config_string
- bindings::rd_kafka_event_debug_contexts
- bindings::rd_kafka_event_destroy
- bindings::rd_kafka_event_error
- bindings::rd_kafka_event_error_is_fatal
- bindings::rd_kafka_event_error_string
- bindings::rd_kafka_event_log
- bindings::rd_kafka_event_message_array
- bindings::rd_kafka_event_message_count
- bindings::rd_kafka_event_message_next
- bindings::rd_kafka_event_name
- bindings::rd_kafka_event_opaque
- bindings::rd_kafka_event_stats
- bindings::rd_kafka_event_topic_partition
- bindings::rd_kafka_event_topic_partition_list
- bindings::rd_kafka_event_type
- bindings::rd_kafka_fatal_error
- bindings::rd_kafka_flush
- bindings::rd_kafka_get_debug_contexts
- bindings::rd_kafka_get_err_descs
- bindings::rd_kafka_get_watermark_offsets
- bindings::rd_kafka_group_list_destroy
- bindings::rd_kafka_group_result_error
- bindings::rd_kafka_group_result_name
- bindings::rd_kafka_group_result_partitions
- bindings::rd_kafka_header_add
- bindings::rd_kafka_header_cnt
- bindings::rd_kafka_header_get
- bindings::rd_kafka_header_get_all
- bindings::rd_kafka_header_get_last
- bindings::rd_kafka_header_remove
- bindings::rd_kafka_headers_copy
- bindings::rd_kafka_headers_destroy
- bindings::rd_kafka_headers_new
- bindings::rd_kafka_incremental_assign
- bindings::rd_kafka_incremental_unassign
- bindings::rd_kafka_init_transactions
- bindings::rd_kafka_interceptor_add_on_acknowledgement
- bindings::rd_kafka_interceptor_add_on_commit
- bindings::rd_kafka_interceptor_add_on_consume
- bindings::rd_kafka_interceptor_add_on_destroy
- bindings::rd_kafka_interceptor_add_on_request_sent
- bindings::rd_kafka_interceptor_add_on_response_received
- bindings::rd_kafka_interceptor_add_on_send
- bindings::rd_kafka_interceptor_add_on_thread_exit
- bindings::rd_kafka_interceptor_add_on_thread_start
- bindings::rd_kafka_last_error
- bindings::rd_kafka_list_groups
- bindings::rd_kafka_log_print
- bindings::rd_kafka_log_syslog
- bindings::rd_kafka_mem_calloc
- bindings::rd_kafka_mem_free
- bindings::rd_kafka_mem_malloc
- bindings::rd_kafka_memberid
- bindings::rd_kafka_message_broker_id
- bindings::rd_kafka_message_destroy
- bindings::rd_kafka_message_detach_headers
- bindings::rd_kafka_message_errstr
- bindings::rd_kafka_message_headers
- bindings::rd_kafka_message_latency
- bindings::rd_kafka_message_set_headers
- bindings::rd_kafka_message_status
- bindings::rd_kafka_message_timestamp
- bindings::rd_kafka_metadata
- bindings::rd_kafka_metadata_destroy
- bindings::rd_kafka_msg_partitioner_consistent
- bindings::rd_kafka_msg_partitioner_consistent_random
- bindings::rd_kafka_msg_partitioner_fnv1a
- bindings::rd_kafka_msg_partitioner_fnv1a_random
- bindings::rd_kafka_msg_partitioner_murmur2
- bindings::rd_kafka_msg_partitioner_murmur2_random
- bindings::rd_kafka_msg_partitioner_random
- bindings::rd_kafka_name
- bindings::rd_kafka_new
- bindings::rd_kafka_oauthbearer_set_token
- bindings::rd_kafka_oauthbearer_set_token_failure
- bindings::rd_kafka_offset_store
- bindings::rd_kafka_offsets_for_times
- bindings::rd_kafka_offsets_store
- bindings::rd_kafka_opaque
- bindings::rd_kafka_outq_len
- bindings::rd_kafka_pause_partitions
- bindings::rd_kafka_poll
- bindings::rd_kafka_poll_set_consumer
- bindings::rd_kafka_position
- bindings::rd_kafka_produce
- bindings::rd_kafka_produce_batch
- bindings::rd_kafka_producev
- bindings::rd_kafka_produceva
- bindings::rd_kafka_purge
- bindings::rd_kafka_query_watermark_offsets
- bindings::rd_kafka_queue_cb_event_enable
- bindings::rd_kafka_queue_destroy
- bindings::rd_kafka_queue_forward
- bindings::rd_kafka_queue_get_background
- bindings::rd_kafka_queue_get_consumer
- bindings::rd_kafka_queue_get_main
- bindings::rd_kafka_queue_get_partition
- bindings::rd_kafka_queue_io_event_enable
- bindings::rd_kafka_queue_length
- bindings::rd_kafka_queue_new
- bindings::rd_kafka_queue_poll
- bindings::rd_kafka_queue_poll_callback
- bindings::rd_kafka_queue_yield
- bindings::rd_kafka_rebalance_protocol
- bindings::rd_kafka_resume_partitions
- bindings::rd_kafka_seek
- bindings::rd_kafka_seek_partitions
- bindings::rd_kafka_send_offsets_to_transaction
- bindings::rd_kafka_set_log_level
- bindings::rd_kafka_set_log_queue
- bindings::rd_kafka_set_logger
- bindings::rd_kafka_subscribe
- bindings::rd_kafka_subscription
- bindings::rd_kafka_test_fatal_error
- bindings::rd_kafka_thread_cnt
- bindings::rd_kafka_topic_conf_destroy
- bindings::rd_kafka_topic_conf_dump
- bindings::rd_kafka_topic_conf_dup
- bindings::rd_kafka_topic_conf_get
- bindings::rd_kafka_topic_conf_new
- bindings::rd_kafka_topic_conf_set
- bindings::rd_kafka_topic_conf_set_msg_order_cmp
- bindings::rd_kafka_topic_conf_set_opaque
- bindings::rd_kafka_topic_conf_set_partitioner_cb
- bindings::rd_kafka_topic_destroy
- bindings::rd_kafka_topic_name
- bindings::rd_kafka_topic_new
- bindings::rd_kafka_topic_opaque
- bindings::rd_kafka_topic_partition_available
- bindings::rd_kafka_topic_partition_destroy
- bindings::rd_kafka_topic_partition_list_add
- bindings::rd_kafka_topic_partition_list_add_range
- bindings::rd_kafka_topic_partition_list_copy
- bindings::rd_kafka_topic_partition_list_del
- bindings::rd_kafka_topic_partition_list_del_by_idx
- bindings::rd_kafka_topic_partition_list_destroy
- bindings::rd_kafka_topic_partition_list_find
- bindings::rd_kafka_topic_partition_list_new
- bindings::rd_kafka_topic_partition_list_set_offset
- bindings::rd_kafka_topic_partition_list_sort
- bindings::rd_kafka_topic_result_error
- bindings::rd_kafka_topic_result_error_string
- bindings::rd_kafka_topic_result_name
- bindings::rd_kafka_type
- bindings::rd_kafka_unittest
- bindings::rd_kafka_unsubscribe
- bindings::rd_kafka_version
- bindings::rd_kafka_version_str
- bindings::rd_kafka_wait_destroyed
- bindings::rd_kafka_yield
- helpers::rd_kafka_resp_err_t_to_rdkafka_error
Typedefs
- bindings::rd_kafka_AdminOptions_t
- bindings::rd_kafka_AlterConfigs_result_t
- bindings::rd_kafka_ConfigEntry_t
- bindings::rd_kafka_ConfigResource_t
- bindings::rd_kafka_CreatePartitions_result_t
- bindings::rd_kafka_CreateTopics_result_t
- bindings::rd_kafka_DeleteConsumerGroupOffsets_result_t
- bindings::rd_kafka_DeleteConsumerGroupOffsets_t
- bindings::rd_kafka_DeleteGroup_t
- bindings::rd_kafka_DeleteGroups_result_t
- bindings::rd_kafka_DeleteRecords_result_t
- bindings::rd_kafka_DeleteRecords_t
- bindings::rd_kafka_DeleteTopic_t
- bindings::rd_kafka_DeleteTopics_result_t
- bindings::rd_kafka_DescribeConfigs_result_t
- bindings::rd_kafka_NewPartitions_t
- bindings::rd_kafka_NewTopic_t
- bindings::rd_kafka_conf_t
- bindings::rd_kafka_consumer_group_metadata_t
- bindings::rd_kafka_error_t
- bindings::rd_kafka_event_t
- bindings::rd_kafka_event_type_t
- bindings::rd_kafka_group_result_t
- bindings::rd_kafka_headers_t
- bindings::rd_kafka_interceptor_f_on_acknowledgement_t
- bindings::rd_kafka_interceptor_f_on_commit_t
- bindings::rd_kafka_interceptor_f_on_conf_destroy_t
- bindings::rd_kafka_interceptor_f_on_conf_dup_t
- bindings::rd_kafka_interceptor_f_on_conf_set_t
- bindings::rd_kafka_interceptor_f_on_consume_t
- bindings::rd_kafka_interceptor_f_on_destroy_t
- bindings::rd_kafka_interceptor_f_on_new_t
- bindings::rd_kafka_interceptor_f_on_request_sent_t
- bindings::rd_kafka_interceptor_f_on_response_received_t
- bindings::rd_kafka_interceptor_f_on_send_t
- bindings::rd_kafka_interceptor_f_on_thread_exit_t
- bindings::rd_kafka_interceptor_f_on_thread_start_t
- bindings::rd_kafka_message_t
- bindings::rd_kafka_metadata_broker_t
- bindings::rd_kafka_metadata_partition_t
- bindings::rd_kafka_metadata_t
- bindings::rd_kafka_metadata_topic_t
- bindings::rd_kafka_plugin_f_conf_init_t
- bindings::rd_kafka_queue_t
- bindings::rd_kafka_t
- bindings::rd_kafka_topic_conf_t
- bindings::rd_kafka_topic_partition_list_t
- bindings::rd_kafka_topic_partition_t
- bindings::rd_kafka_topic_result_t
- bindings::rd_kafka_topic_t
- bindings::rd_kafka_vu_t
- types::RDKafka
- types::RDKafkaAdminOptions
- types::RDKafkaConf
- types::RDKafkaConfigResource
- types::RDKafkaConsumerGroupMetadata
- types::RDKafkaDeleteTopic
- types::RDKafkaEvent
- types::RDKafkaGroupInfo
- types::RDKafkaGroupList
- types::RDKafkaGroupMemberInfo
- types::RDKafkaHeaders
- types::RDKafkaMessage
- types::RDKafkaMetadata
- types::RDKafkaMetadataBroker
- types::RDKafkaMetadataPartition
- types::RDKafkaMetadataTopic
- types::RDKafkaNewPartitions
- types::RDKafkaNewTopic
- types::RDKafkaQueue
- types::RDKafkaState
- types::RDKafkaTopic
- types::RDKafkaTopicConf
- types::RDKafkaTopicPartition
- types::RDKafkaTopicPartitionList
- types::RDKafkaTopicResult
Constants
- bindings::RD_KAFKA_DEBUG_CONTEXTS
- bindings::RD_KAFKA_DESTROY_F_NO_CONSUMER_CLOSE
- bindings::RD_KAFKA_EVENT_ALTERCONFIGS_RESULT
- bindings::RD_KAFKA_EVENT_CREATEPARTITIONS_RESULT
- bindings::RD_KAFKA_EVENT_CREATETOPICS_RESULT
- bindings::RD_KAFKA_EVENT_DELETECONSUMERGROUPOFFSETS_RESULT
- bindings::RD_KAFKA_EVENT_DELETEGROUPS_RESULT
- bindings::RD_KAFKA_EVENT_DELETERECORDS_RESULT
- bindings::RD_KAFKA_EVENT_DELETETOPICS_RESULT
- bindings::RD_KAFKA_EVENT_DESCRIBECONFIGS_RESULT
- bindings::RD_KAFKA_EVENT_DR
- bindings::RD_KAFKA_EVENT_ERROR
- bindings::RD_KAFKA_EVENT_FETCH
- bindings::RD_KAFKA_EVENT_LOG
- bindings::RD_KAFKA_EVENT_NONE
- bindings::RD_KAFKA_EVENT_OAUTHBEARER_TOKEN_REFRESH
- bindings::RD_KAFKA_EVENT_OFFSET_COMMIT
- bindings::RD_KAFKA_EVENT_REBALANCE
- bindings::RD_KAFKA_EVENT_STATS
- bindings::RD_KAFKA_MSG_F_BLOCK
- bindings::RD_KAFKA_MSG_F_COPY
- bindings::RD_KAFKA_MSG_F_FREE
- bindings::RD_KAFKA_MSG_F_PARTITION
- bindings::RD_KAFKA_OFFSET_BEGINNING
- bindings::RD_KAFKA_OFFSET_END
- bindings::RD_KAFKA_OFFSET_INVALID
- bindings::RD_KAFKA_OFFSET_STORED
- bindings::RD_KAFKA_OFFSET_TAIL_BASE
- bindings::RD_KAFKA_PURGE_F_INFLIGHT
- bindings::RD_KAFKA_PURGE_F_NON_BLOCKING
- bindings::RD_KAFKA_PURGE_F_QUEUE
- bindings::RD_KAFKA_VERSION