Docs.rs
rdkafka-0.36.2
rdkafka 0.36.2
Permalink
Docs.rs crate page
MIT
Links
Repository
crates.io
Source
Owners
fede1024
flavray
benesch
davidblewett
mborst
scanterog
Dependencies
futures-channel ^0.3.0
normal
futures-executor ^0.3.0
normal
futures-util ^0.3.0
normal
libc ^0.2.0
normal
log ^0.4.8
normal
rdkafka-sys ^4.7.0
normal
serde ^1.0.0
normal
serde_derive ^1.0.0
normal
serde_json ^1.0.0
normal
slab ^0.4
normal
tokio ^1.18
normal
tracing ^0.1.30
normal
async-std ^1.9.0
dev
backoff ^0.1.5
dev
chrono ^0.4.0
dev
clap ^2.18.0
dev
env_logger ^0.9.0
dev
futures ^0.3.0
dev
hdrhistogram ^7.0.0
dev
maplit ^1.0.2
dev
rand ^0.3.15
dev
regex ^1.1.6
dev
smol ^1.2.4
dev
tokio ^1.18
dev
Versions
100%
of the crate is documented
Platform
x86_64-unknown-linux-gnu
Feature flags
Rust
About docs.rs
Privacy policy
Rust website
The Book
Standard Library API Reference
Rust by Example
The Cargo Guide
Clippy Documentation
rdkafka
0.36.2
Module bindings
Structs
Enums
Constants
Functions
Type Aliases
Unions
In crate rdkafka
?
Module
rdkafka
::
bindings
source
·
[
−
]
Expand description
FFI bindings.
These bindings are automatically generated with
bindgen
.
Structs
rd_kafka_AclBinding_s
rd_kafka_AdminOptions_s
rd_kafka_AlterConsumerGroupOffsets_s
rd_kafka_AlterUserScramCredentials_result_response_s
rd_kafka_ConfigEntry_s
rd_kafka_ConfigResource_s
rd_kafka_ConsumerGroupDescription_s
rd_kafka_ConsumerGroupListing_s
rd_kafka_DeleteAcls_result_response_s
rd_kafka_DeleteConsumerGroupOffsets_s
rd_kafka_DeleteGroup_s
rd_kafka_DeleteRecords_s
rd_kafka_DeleteTopic_s
rd_kafka_ListConsumerGroupOffsets_s
rd_kafka_ListConsumerGroupsResult_s
rd_kafka_ListOffsetsResultInfo_s
rd_kafka_MemberAssignment_s
rd_kafka_MemberDescription_s
rd_kafka_NewPartitions_s
rd_kafka_NewTopic_s
rd_kafka_Node_s
rd_kafka_ScramCredentialInfo_s
rd_kafka_TopicCollection_s
rd_kafka_TopicDescription_s
rd_kafka_TopicPartitionInfo_s
rd_kafka_UserScramCredentialAlteration_s
rd_kafka_UserScramCredentialsDescription_s
rd_kafka_Uuid_s
rd_kafka_acl_result_s
rd_kafka_conf_s
rd_kafka_consumer_group_metadata_s
rd_kafka_err_desc
rd_kafka_error_s
rd_kafka_group_info
rd_kafka_group_list
rd_kafka_group_member_info
rd_kafka_group_result_s
rd_kafka_headers_s
rd_kafka_message_s
rd_kafka_metadata
rd_kafka_metadata_broker
rd_kafka_metadata_partition
rd_kafka_metadata_topic
rd_kafka_mock_cluster_s
rd_kafka_mock_request_s
rd_kafka_op_s
rd_kafka_queue_s
rd_kafka_s
rd_kafka_topic_conf_s
rd_kafka_topic_partition_list_s
rd_kafka_topic_partition_s
rd_kafka_topic_result_s
rd_kafka_topic_s
rd_kafka_vu_s
rd_kafka_vu_s__bindgen_ty_1__bindgen_ty_1
rd_kafka_vu_s__bindgen_ty_1__bindgen_ty_2
Enums
rd_kafka_AclOperation_t
rd_kafka_AclPermissionType_t
rd_kafka_AlterConfigOpType_t
rd_kafka_ConfigSource_t
rd_kafka_IsolationLevel_t
rd_kafka_OffsetSpec_t
rd_kafka_ResourcePatternType_t
rd_kafka_ResourceType_t
rd_kafka_ScramMechanism_t
rd_kafka_admin_op_t
rd_kafka_cert_enc_t
rd_kafka_cert_type_t
rd_kafka_conf_res_t
rd_kafka_consumer_group_state_t
rd_kafka_msg_status_t
rd_kafka_resp_err_t
rd_kafka_thread_type_t
rd_kafka_timestamp_type_t
rd_kafka_type_t
rd_kafka_vtype_t
Constants
RD_KAFKA_DEBUG_CONTEXTS
RD_KAFKA_DESTROY_F_NO_CONSUMER_CLOSE
RD_KAFKA_EVENT_ALTERCONFIGS_RESULT
RD_KAFKA_EVENT_ALTERCONSUMERGROUPOFFSETS_RESULT
RD_KAFKA_EVENT_ALTERUSERSCRAMCREDENTIALS_RESULT
RD_KAFKA_EVENT_BACKGROUND
RD_KAFKA_EVENT_CREATEACLS_RESULT
RD_KAFKA_EVENT_CREATEPARTITIONS_RESULT
RD_KAFKA_EVENT_CREATETOPICS_RESULT
RD_KAFKA_EVENT_DELETEACLS_RESULT
RD_KAFKA_EVENT_DELETECONSUMERGROUPOFFSETS_RESULT
RD_KAFKA_EVENT_DELETEGROUPS_RESULT
RD_KAFKA_EVENT_DELETERECORDS_RESULT
RD_KAFKA_EVENT_DELETETOPICS_RESULT
RD_KAFKA_EVENT_DESCRIBEACLS_RESULT
RD_KAFKA_EVENT_DESCRIBECLUSTER_RESULT
RD_KAFKA_EVENT_DESCRIBECONFIGS_RESULT
RD_KAFKA_EVENT_DESCRIBECONSUMERGROUPS_RESULT
RD_KAFKA_EVENT_DESCRIBETOPICS_RESULT
RD_KAFKA_EVENT_DESCRIBEUSERSCRAMCREDENTIALS_RESULT
RD_KAFKA_EVENT_DR
RD_KAFKA_EVENT_ERROR
RD_KAFKA_EVENT_FETCH
RD_KAFKA_EVENT_INCREMENTALALTERCONFIGS_RESULT
RD_KAFKA_EVENT_LISTCONSUMERGROUPOFFSETS_RESULT
RD_KAFKA_EVENT_LISTCONSUMERGROUPS_RESULT
RD_KAFKA_EVENT_LISTOFFSETS_RESULT
RD_KAFKA_EVENT_LOG
RD_KAFKA_EVENT_NONE
RD_KAFKA_EVENT_OAUTHBEARER_TOKEN_REFRESH
RD_KAFKA_EVENT_OFFSET_COMMIT
RD_KAFKA_EVENT_REBALANCE
RD_KAFKA_EVENT_STATS
RD_KAFKA_MSG_F_BLOCK
RD_KAFKA_MSG_F_COPY
RD_KAFKA_MSG_F_FREE
RD_KAFKA_MSG_F_PARTITION
RD_KAFKA_OFFSET_BEGINNING
RD_KAFKA_OFFSET_END
RD_KAFKA_OFFSET_INVALID
RD_KAFKA_OFFSET_STORED
RD_KAFKA_OFFSET_TAIL_BASE
RD_KAFKA_PURGE_F_INFLIGHT
RD_KAFKA_PURGE_F_NON_BLOCKING
RD_KAFKA_PURGE_F_QUEUE
RD_KAFKA_VERSION
Functions
rd_kafka_AclBindingFilter_new
⚠
rd_kafka_AclBinding_destroy
⚠
rd_kafka_AclBinding_destroy_array
⚠
rd_kafka_AclBinding_error
⚠
rd_kafka_AclBinding_host
⚠
rd_kafka_AclBinding_name
⚠
rd_kafka_AclBinding_new
⚠
rd_kafka_AclBinding_operation
⚠
rd_kafka_AclBinding_permission_type
⚠
rd_kafka_AclBinding_principal
⚠
rd_kafka_AclBinding_resource_pattern_type
⚠
rd_kafka_AclBinding_restype
⚠
rd_kafka_AclOperation_name
⚠
rd_kafka_AclPermissionType_name
⚠
rd_kafka_AdminOptions_destroy
⚠
rd_kafka_AdminOptions_new
⚠
rd_kafka_AdminOptions_set_broker
⚠
rd_kafka_AdminOptions_set_include_authorized_operations
⚠
rd_kafka_AdminOptions_set_isolation_level
⚠
rd_kafka_AdminOptions_set_match_consumer_group_states
⚠
rd_kafka_AdminOptions_set_opaque
⚠
rd_kafka_AdminOptions_set_operation_timeout
⚠
rd_kafka_AdminOptions_set_request_timeout
⚠
rd_kafka_AdminOptions_set_require_stable_offsets
⚠
rd_kafka_AdminOptions_set_validate_only
⚠
rd_kafka_AlterConfigs
⚠
rd_kafka_AlterConfigs_result_resources
⚠
rd_kafka_AlterConsumerGroupOffsets
⚠
rd_kafka_AlterConsumerGroupOffsets_destroy
⚠
rd_kafka_AlterConsumerGroupOffsets_destroy_array
⚠
rd_kafka_AlterConsumerGroupOffsets_new
⚠
rd_kafka_AlterConsumerGroupOffsets_result_groups
⚠
rd_kafka_AlterUserScramCredentials
⚠
rd_kafka_AlterUserScramCredentials_result_response_error
⚠
rd_kafka_AlterUserScramCredentials_result_response_user
⚠
rd_kafka_AlterUserScramCredentials_result_responses
⚠
rd_kafka_ConfigEntry_is_default
⚠
rd_kafka_ConfigEntry_is_read_only
⚠
rd_kafka_ConfigEntry_is_sensitive
⚠
rd_kafka_ConfigEntry_is_synonym
⚠
rd_kafka_ConfigEntry_name
⚠
rd_kafka_ConfigEntry_source
⚠
rd_kafka_ConfigEntry_synonyms
⚠
rd_kafka_ConfigEntry_value
⚠
rd_kafka_ConfigResource_add_incremental_config
⚠
rd_kafka_ConfigResource_configs
⚠
rd_kafka_ConfigResource_destroy
⚠
rd_kafka_ConfigResource_destroy_array
⚠
rd_kafka_ConfigResource_error
⚠
rd_kafka_ConfigResource_error_string
⚠
rd_kafka_ConfigResource_name
⚠
rd_kafka_ConfigResource_new
⚠
rd_kafka_ConfigResource_set_config
⚠
rd_kafka_ConfigResource_type
⚠
rd_kafka_ConfigSource_name
⚠
rd_kafka_ConsumerGroupDescription_authorized_operations
⚠
rd_kafka_ConsumerGroupDescription_coordinator
⚠
rd_kafka_ConsumerGroupDescription_error
⚠
rd_kafka_ConsumerGroupDescription_group_id
⚠
rd_kafka_ConsumerGroupDescription_is_simple_consumer_group
⚠
rd_kafka_ConsumerGroupDescription_member
⚠
rd_kafka_ConsumerGroupDescription_member_count
⚠
rd_kafka_ConsumerGroupDescription_partition_assignor
⚠
rd_kafka_ConsumerGroupDescription_state
⚠
rd_kafka_ConsumerGroupListing_group_id
⚠
rd_kafka_ConsumerGroupListing_is_simple_consumer_group
⚠
rd_kafka_ConsumerGroupListing_state
⚠
rd_kafka_CreateAcls
⚠
rd_kafka_CreateAcls_result_acls
⚠
rd_kafka_CreatePartitions
⚠
rd_kafka_CreatePartitions_result_topics
⚠
rd_kafka_CreateTopics
⚠
rd_kafka_CreateTopics_result_topics
⚠
rd_kafka_DeleteAcls
⚠
rd_kafka_DeleteAcls_result_response_error
⚠
rd_kafka_DeleteAcls_result_response_matching_acls
⚠
rd_kafka_DeleteAcls_result_responses
⚠
rd_kafka_DeleteConsumerGroupOffsets
⚠
rd_kafka_DeleteConsumerGroupOffsets_destroy
⚠
rd_kafka_DeleteConsumerGroupOffsets_destroy_array
⚠
rd_kafka_DeleteConsumerGroupOffsets_new
⚠
rd_kafka_DeleteConsumerGroupOffsets_result_groups
⚠
rd_kafka_DeleteGroup_destroy
⚠
rd_kafka_DeleteGroup_destroy_array
⚠
rd_kafka_DeleteGroup_new
⚠
rd_kafka_DeleteGroups
⚠
rd_kafka_DeleteGroups_result_groups
⚠
rd_kafka_DeleteRecords
⚠
rd_kafka_DeleteRecords_destroy
⚠
rd_kafka_DeleteRecords_destroy_array
⚠
rd_kafka_DeleteRecords_new
⚠
rd_kafka_DeleteRecords_result_offsets
⚠
rd_kafka_DeleteTopic_destroy
⚠
rd_kafka_DeleteTopic_destroy_array
⚠
rd_kafka_DeleteTopic_new
⚠
rd_kafka_DeleteTopics
⚠
rd_kafka_DeleteTopics_result_topics
⚠
rd_kafka_DescribeAcls
⚠
rd_kafka_DescribeAcls_result_acls
⚠
rd_kafka_DescribeCluster
⚠
rd_kafka_DescribeCluster_result_authorized_operations
⚠
rd_kafka_DescribeCluster_result_cluster_id
⚠
rd_kafka_DescribeCluster_result_controller
⚠
rd_kafka_DescribeCluster_result_nodes
⚠
rd_kafka_DescribeConfigs
⚠
rd_kafka_DescribeConfigs_result_resources
⚠
rd_kafka_DescribeConsumerGroups
⚠
rd_kafka_DescribeConsumerGroups_result_groups
⚠
rd_kafka_DescribeTopics
⚠
rd_kafka_DescribeTopics_result_topics
⚠
rd_kafka_DescribeUserScramCredentials
⚠
rd_kafka_DescribeUserScramCredentials_result_descriptions
⚠
rd_kafka_IncrementalAlterConfigs
⚠
rd_kafka_IncrementalAlterConfigs_result_resources
⚠
rd_kafka_ListConsumerGroupOffsets
⚠
rd_kafka_ListConsumerGroupOffsets_destroy
⚠
rd_kafka_ListConsumerGroupOffsets_destroy_array
⚠
rd_kafka_ListConsumerGroupOffsets_new
⚠
rd_kafka_ListConsumerGroupOffsets_result_groups
⚠
rd_kafka_ListConsumerGroups
⚠
rd_kafka_ListConsumerGroups_result_errors
⚠
rd_kafka_ListConsumerGroups_result_valid
⚠
rd_kafka_ListOffsets
⚠
rd_kafka_ListOffsetsResultInfo_timestamp
⚠
rd_kafka_ListOffsetsResultInfo_topic_partition
⚠
rd_kafka_ListOffsets_result_infos
⚠
rd_kafka_MemberAssignment_partitions
⚠
rd_kafka_MemberDescription_assignment
⚠
rd_kafka_MemberDescription_client_id
⚠
rd_kafka_MemberDescription_consumer_id
⚠
rd_kafka_MemberDescription_group_instance_id
⚠
rd_kafka_MemberDescription_host
⚠
rd_kafka_NewPartitions_destroy
⚠
rd_kafka_NewPartitions_destroy_array
⚠
rd_kafka_NewPartitions_new
⚠
rd_kafka_NewPartitions_set_replica_assignment
⚠
rd_kafka_NewTopic_destroy
⚠
rd_kafka_NewTopic_destroy_array
⚠
rd_kafka_NewTopic_new
⚠
rd_kafka_NewTopic_set_config
⚠
rd_kafka_NewTopic_set_replica_assignment
⚠
rd_kafka_Node_host
⚠
rd_kafka_Node_id
⚠
rd_kafka_Node_port
⚠
rd_kafka_Node_rack
⚠
rd_kafka_ResourcePatternType_name
⚠
rd_kafka_ResourceType_name
⚠
rd_kafka_ScramCredentialInfo_iterations
⚠
rd_kafka_ScramCredentialInfo_mechanism
⚠
rd_kafka_TopicCollection_destroy
⚠
rd_kafka_TopicCollection_of_topic_names
⚠
rd_kafka_TopicDescription_authorized_operations
⚠
rd_kafka_TopicDescription_error
⚠
rd_kafka_TopicDescription_is_internal
⚠
rd_kafka_TopicDescription_name
⚠
rd_kafka_TopicDescription_partitions
⚠
rd_kafka_TopicDescription_topic_id
⚠
rd_kafka_TopicPartitionInfo_isr
⚠
rd_kafka_TopicPartitionInfo_leader
⚠
rd_kafka_TopicPartitionInfo_partition
⚠
rd_kafka_TopicPartitionInfo_replicas
⚠
rd_kafka_UserScramCredentialAlteration_destroy
⚠
rd_kafka_UserScramCredentialAlteration_destroy_array
⚠
rd_kafka_UserScramCredentialDeletion_new
⚠
rd_kafka_UserScramCredentialUpsertion_new
⚠
rd_kafka_UserScramCredentialsDescription_error
⚠
rd_kafka_UserScramCredentialsDescription_scramcredentialinfo
⚠
rd_kafka_UserScramCredentialsDescription_scramcredentialinfo_count
⚠
rd_kafka_UserScramCredentialsDescription_user
⚠
rd_kafka_Uuid_base64str
⚠
rd_kafka_Uuid_copy
⚠
rd_kafka_Uuid_destroy
⚠
rd_kafka_Uuid_least_significant_bits
⚠
rd_kafka_Uuid_most_significant_bits
⚠
rd_kafka_Uuid_new
⚠
rd_kafka_abort_transaction
⚠
rd_kafka_acl_result_error
⚠
rd_kafka_assign
⚠
rd_kafka_assignment
⚠
rd_kafka_assignment_lost
⚠
rd_kafka_begin_transaction
⚠
rd_kafka_brokers_add
⚠
rd_kafka_clusterid
⚠
rd_kafka_commit
⚠
rd_kafka_commit_message
⚠
rd_kafka_commit_queue
⚠
rd_kafka_commit_transaction
⚠
rd_kafka_committed
⚠
rd_kafka_conf
⚠
rd_kafka_conf_destroy
⚠
rd_kafka_conf_dump
⚠
rd_kafka_conf_dump_free
⚠
rd_kafka_conf_dup
⚠
rd_kafka_conf_dup_filter
⚠
rd_kafka_conf_enable_sasl_queue
⚠
rd_kafka_conf_get
⚠
rd_kafka_conf_get_default_topic_conf
⚠
rd_kafka_conf_interceptor_add_on_conf_destroy
⚠
rd_kafka_conf_interceptor_add_on_conf_dup
⚠
rd_kafka_conf_interceptor_add_on_conf_set
⚠
rd_kafka_conf_interceptor_add_on_new
⚠
rd_kafka_conf_new
⚠
rd_kafka_conf_properties_show
⚠
rd_kafka_conf_set
⚠
rd_kafka_conf_set_background_event_cb
⚠
rd_kafka_conf_set_closesocket_cb
⚠
rd_kafka_conf_set_connect_cb
⚠
rd_kafka_conf_set_consume_cb
⚠
rd_kafka_conf_set_default_topic_conf
⚠
rd_kafka_conf_set_dr_cb
⚠
rd_kafka_conf_set_dr_msg_cb
⚠
rd_kafka_conf_set_engine_callback_data
⚠
rd_kafka_conf_set_error_cb
⚠
rd_kafka_conf_set_events
⚠
rd_kafka_conf_set_log_cb
⚠
rd_kafka_conf_set_oauthbearer_token_refresh_cb
⚠
rd_kafka_conf_set_offset_commit_cb
⚠
rd_kafka_conf_set_opaque
⚠
rd_kafka_conf_set_rebalance_cb
⚠
rd_kafka_conf_set_socket_cb
⚠
rd_kafka_conf_set_ssl_cert
⚠
rd_kafka_conf_set_ssl_cert_verify_cb
⚠
rd_kafka_conf_set_stats_cb
⚠
rd_kafka_conf_set_throttle_cb
⚠
rd_kafka_consume
⚠
rd_kafka_consume_batch
⚠
rd_kafka_consume_batch_queue
⚠
rd_kafka_consume_callback
⚠
rd_kafka_consume_callback_queue
⚠
rd_kafka_consume_queue
⚠
rd_kafka_consume_start
⚠
rd_kafka_consume_start_queue
⚠
rd_kafka_consume_stop
⚠
rd_kafka_consumer_close
⚠
rd_kafka_consumer_close_queue
⚠
rd_kafka_consumer_closed
⚠
rd_kafka_consumer_group_metadata
⚠
rd_kafka_consumer_group_metadata_destroy
⚠
rd_kafka_consumer_group_metadata_new
⚠
rd_kafka_consumer_group_metadata_new_with_genid
⚠
rd_kafka_consumer_group_metadata_read
⚠
rd_kafka_consumer_group_metadata_write
⚠
rd_kafka_consumer_group_state_code
⚠
rd_kafka_consumer_group_state_name
⚠
rd_kafka_consumer_poll
⚠
rd_kafka_controllerid
⚠
rd_kafka_default_topic_conf_dup
⚠
rd_kafka_destroy
⚠
rd_kafka_destroy_flags
⚠
rd_kafka_dump
⚠
rd_kafka_err2name
⚠
rd_kafka_err2str
⚠
rd_kafka_errno
⚠
rd_kafka_errno2err
⚠
rd_kafka_error_code
⚠
rd_kafka_error_destroy
⚠
rd_kafka_error_is_fatal
⚠
rd_kafka_error_is_retriable
⚠
rd_kafka_error_name
⚠
rd_kafka_error_new
⚠
rd_kafka_error_string
⚠
rd_kafka_error_txn_requires_abort
⚠
rd_kafka_event_AlterConfigs_result
⚠
rd_kafka_event_AlterConsumerGroupOffsets_result
⚠
rd_kafka_event_AlterUserScramCredentials_result
⚠
rd_kafka_event_CreateAcls_result
⚠
rd_kafka_event_CreatePartitions_result
⚠
rd_kafka_event_CreateTopics_result
⚠
rd_kafka_event_DeleteAcls_result
⚠
rd_kafka_event_DeleteConsumerGroupOffsets_result
⚠
rd_kafka_event_DeleteGroups_result
⚠
rd_kafka_event_DeleteRecords_result
⚠
rd_kafka_event_DeleteTopics_result
⚠
rd_kafka_event_DescribeAcls_result
⚠
rd_kafka_event_DescribeCluster_result
⚠
rd_kafka_event_DescribeConfigs_result
⚠
rd_kafka_event_DescribeConsumerGroups_result
⚠
rd_kafka_event_DescribeTopics_result
⚠
rd_kafka_event_DescribeUserScramCredentials_result
⚠
rd_kafka_event_IncrementalAlterConfigs_result
⚠
rd_kafka_event_ListConsumerGroupOffsets_result
⚠
rd_kafka_event_ListConsumerGroups_result
⚠
rd_kafka_event_ListOffsets_result
⚠
rd_kafka_event_config_string
⚠
rd_kafka_event_debug_contexts
⚠
rd_kafka_event_destroy
⚠
rd_kafka_event_error
⚠
rd_kafka_event_error_is_fatal
⚠
rd_kafka_event_error_string
⚠
rd_kafka_event_log
⚠
rd_kafka_event_message_array
⚠
rd_kafka_event_message_count
⚠
rd_kafka_event_message_next
⚠
rd_kafka_event_name
⚠
rd_kafka_event_opaque
⚠
rd_kafka_event_stats
⚠
rd_kafka_event_topic_partition
⚠
rd_kafka_event_topic_partition_list
⚠
rd_kafka_event_type
⚠
rd_kafka_fatal_error
⚠
rd_kafka_flush
⚠
rd_kafka_get_debug_contexts
⚠
rd_kafka_get_err_descs
⚠
rd_kafka_get_watermark_offsets
⚠
rd_kafka_group_list_destroy
⚠
rd_kafka_group_result_error
⚠
rd_kafka_group_result_name
⚠
rd_kafka_group_result_partitions
⚠
rd_kafka_handle_mock_cluster
⚠
rd_kafka_header_add
⚠
rd_kafka_header_cnt
⚠
rd_kafka_header_get
⚠
rd_kafka_header_get_all
⚠
rd_kafka_header_get_last
⚠
rd_kafka_header_remove
⚠
rd_kafka_headers_copy
⚠
rd_kafka_headers_destroy
⚠
rd_kafka_headers_new
⚠
rd_kafka_incremental_assign
⚠
rd_kafka_incremental_unassign
⚠
rd_kafka_init_transactions
⚠
rd_kafka_interceptor_add_on_acknowledgement
⚠
rd_kafka_interceptor_add_on_broker_state_change
⚠
rd_kafka_interceptor_add_on_commit
⚠
rd_kafka_interceptor_add_on_consume
⚠
rd_kafka_interceptor_add_on_destroy
⚠
rd_kafka_interceptor_add_on_request_sent
⚠
rd_kafka_interceptor_add_on_response_received
⚠
rd_kafka_interceptor_add_on_send
⚠
rd_kafka_interceptor_add_on_thread_exit
⚠
rd_kafka_interceptor_add_on_thread_start
⚠
rd_kafka_last_error
⚠
rd_kafka_list_groups
⚠
rd_kafka_log_print
⚠
rd_kafka_log_syslog
⚠
rd_kafka_mem_calloc
⚠
rd_kafka_mem_free
⚠
rd_kafka_mem_malloc
⚠
rd_kafka_memberid
⚠
rd_kafka_message_broker_id
⚠
rd_kafka_message_destroy
⚠
rd_kafka_message_detach_headers
⚠
rd_kafka_message_errstr
⚠
rd_kafka_message_headers
⚠
rd_kafka_message_latency
⚠
rd_kafka_message_leader_epoch
⚠
rd_kafka_message_set_headers
⚠
rd_kafka_message_status
⚠
rd_kafka_message_timestamp
⚠
rd_kafka_metadata
⚠
rd_kafka_metadata_destroy
⚠
rd_kafka_mock_broker_error_stack_cnt
⚠
rd_kafka_mock_broker_push_request_error_rtts
⚠
rd_kafka_mock_broker_set_down
⚠
rd_kafka_mock_broker_set_rack
⚠
rd_kafka_mock_broker_set_rtt
⚠
rd_kafka_mock_broker_set_up
⚠
rd_kafka_mock_clear_request_errors
⚠
rd_kafka_mock_clear_requests
⚠
rd_kafka_mock_cluster_bootstraps
⚠
rd_kafka_mock_cluster_destroy
⚠
rd_kafka_mock_cluster_handle
⚠
rd_kafka_mock_cluster_new
⚠
rd_kafka_mock_coordinator_set
⚠
rd_kafka_mock_get_requests
⚠
rd_kafka_mock_partition_set_follower
⚠
rd_kafka_mock_partition_set_follower_wmarks
⚠
rd_kafka_mock_partition_set_leader
⚠
rd_kafka_mock_push_request_errors
⚠
rd_kafka_mock_push_request_errors_array
⚠
rd_kafka_mock_request_api_key
⚠
rd_kafka_mock_request_destroy
⚠
rd_kafka_mock_request_id
⚠
rd_kafka_mock_request_timestamp
⚠
rd_kafka_mock_set_apiversion
⚠
rd_kafka_mock_start_request_tracking
⚠
rd_kafka_mock_stop_request_tracking
⚠
rd_kafka_mock_topic_create
⚠
rd_kafka_mock_topic_set_error
⚠
rd_kafka_msg_partitioner_consistent
⚠
rd_kafka_msg_partitioner_consistent_random
⚠
rd_kafka_msg_partitioner_fnv1a
⚠
rd_kafka_msg_partitioner_fnv1a_random
⚠
rd_kafka_msg_partitioner_murmur2
⚠
rd_kafka_msg_partitioner_murmur2_random
⚠
rd_kafka_msg_partitioner_random
⚠
rd_kafka_name
⚠
rd_kafka_new
⚠
rd_kafka_oauthbearer_set_token
⚠
rd_kafka_oauthbearer_set_token_failure
⚠
rd_kafka_offset_store
⚠
rd_kafka_offset_store_message
⚠
rd_kafka_offsets_for_times
⚠
rd_kafka_offsets_store
⚠
rd_kafka_opaque
⚠
rd_kafka_outq_len
⚠
rd_kafka_pause_partitions
⚠
rd_kafka_poll
⚠
rd_kafka_poll_set_consumer
⚠
rd_kafka_position
⚠
rd_kafka_produce
⚠
rd_kafka_produce_batch
⚠
rd_kafka_producev
⚠
rd_kafka_produceva
⚠
rd_kafka_purge
⚠
rd_kafka_query_watermark_offsets
⚠
rd_kafka_queue_cb_event_enable
⚠
rd_kafka_queue_destroy
⚠
rd_kafka_queue_forward
⚠
rd_kafka_queue_get_background
⚠
rd_kafka_queue_get_consumer
⚠
rd_kafka_queue_get_main
⚠
rd_kafka_queue_get_partition
⚠
rd_kafka_queue_get_sasl
⚠
rd_kafka_queue_io_event_enable
⚠
rd_kafka_queue_length
⚠
rd_kafka_queue_new
⚠
rd_kafka_queue_poll
⚠
rd_kafka_queue_poll_callback
⚠
rd_kafka_queue_yield
⚠
rd_kafka_rebalance_protocol
⚠
rd_kafka_resume_partitions
⚠
rd_kafka_sasl_background_callbacks_enable
⚠
rd_kafka_sasl_set_credentials
⚠
rd_kafka_seek
⚠
rd_kafka_seek_partitions
⚠
rd_kafka_send_offsets_to_transaction
⚠
rd_kafka_set_log_level
⚠
rd_kafka_set_log_queue
⚠
rd_kafka_set_logger
⚠
rd_kafka_subscribe
⚠
rd_kafka_subscription
⚠
rd_kafka_test_fatal_error
⚠
rd_kafka_thread_cnt
⚠
rd_kafka_topic_conf_destroy
⚠
rd_kafka_topic_conf_dump
⚠
rd_kafka_topic_conf_dup
⚠
rd_kafka_topic_conf_get
⚠
rd_kafka_topic_conf_new
⚠
rd_kafka_topic_conf_set
⚠
rd_kafka_topic_conf_set_msg_order_cmp
⚠
rd_kafka_topic_conf_set_opaque
⚠
rd_kafka_topic_conf_set_partitioner_cb
⚠
rd_kafka_topic_destroy
⚠
rd_kafka_topic_name
⚠
rd_kafka_topic_new
⚠
rd_kafka_topic_opaque
⚠
rd_kafka_topic_partition_available
⚠
rd_kafka_topic_partition_destroy
⚠
rd_kafka_topic_partition_get_leader_epoch
⚠
rd_kafka_topic_partition_list_add
⚠
rd_kafka_topic_partition_list_add_range
⚠
rd_kafka_topic_partition_list_copy
⚠
rd_kafka_topic_partition_list_del
⚠
rd_kafka_topic_partition_list_del_by_idx
⚠
rd_kafka_topic_partition_list_destroy
⚠
rd_kafka_topic_partition_list_find
⚠
rd_kafka_topic_partition_list_new
⚠
rd_kafka_topic_partition_list_set_offset
⚠
rd_kafka_topic_partition_list_sort
⚠
rd_kafka_topic_partition_set_leader_epoch
⚠
rd_kafka_topic_result_error
⚠
rd_kafka_topic_result_error_string
⚠
rd_kafka_topic_result_name
⚠
rd_kafka_type
⚠
rd_kafka_unittest
⚠
rd_kafka_unsubscribe
⚠
rd_kafka_version
⚠
rd_kafka_version_str
⚠
rd_kafka_wait_destroyed
⚠
rd_kafka_yield
⚠
Type Aliases
rd_kafka_AclBindingFilter_t
rd_kafka_AclBinding_t
rd_kafka_AdminOptions_t
rd_kafka_AlterConfigs_result_t
rd_kafka_AlterConsumerGroupOffsets_result_t
rd_kafka_AlterConsumerGroupOffsets_t
rd_kafka_AlterUserScramCredentials_result_response_t
rd_kafka_AlterUserScramCredentials_result_t
rd_kafka_ConfigEntry_t
rd_kafka_ConfigResource_t
rd_kafka_ConsumerGroupDescription_t
rd_kafka_ConsumerGroupListing_t
rd_kafka_CreateAcls_result_t
rd_kafka_CreatePartitions_result_t
rd_kafka_CreateTopics_result_t
rd_kafka_DeleteAcls_result_response_t
rd_kafka_DeleteAcls_result_t
rd_kafka_DeleteConsumerGroupOffsets_result_t
rd_kafka_DeleteConsumerGroupOffsets_t
rd_kafka_DeleteGroup_t
rd_kafka_DeleteGroups_result_t
rd_kafka_DeleteRecords_result_t
rd_kafka_DeleteRecords_t
rd_kafka_DeleteTopic_t
rd_kafka_DeleteTopics_result_t
rd_kafka_DescribeAcls_result_t
rd_kafka_DescribeCluster_result_t
rd_kafka_DescribeConfigs_result_t
rd_kafka_DescribeConsumerGroups_result_t
rd_kafka_DescribeTopics_result_t
rd_kafka_DescribeUserScramCredentials_result_t
rd_kafka_IncrementalAlterConfigs_result_t
rd_kafka_ListConsumerGroupOffsets_result_t
rd_kafka_ListConsumerGroupOffsets_t
rd_kafka_ListConsumerGroupsResult_t
rd_kafka_ListConsumerGroups_result_t
rd_kafka_ListOffsetsResultInfo_t
rd_kafka_ListOffsets_result_t
rd_kafka_MemberAssignment_t
rd_kafka_MemberDescription_t
rd_kafka_NewPartitions_t
rd_kafka_NewTopic_t
rd_kafka_Node_t
rd_kafka_ScramCredentialInfo_t
rd_kafka_TopicCollection_t
rd_kafka_TopicDescription_t
rd_kafka_TopicPartitionInfo_t
rd_kafka_UserScramCredentialAlteration_t
rd_kafka_UserScramCredentialsDescription_t
rd_kafka_Uuid_t
rd_kafka_acl_result_t
rd_kafka_conf_t
rd_kafka_consumer_group_metadata_t
rd_kafka_error_t
rd_kafka_event_t
rd_kafka_event_type_t
rd_kafka_group_result_t
rd_kafka_headers_t
rd_kafka_interceptor_f_on_acknowledgement_t
rd_kafka_interceptor_f_on_broker_state_change_t
rd_kafka_interceptor_f_on_commit_t
rd_kafka_interceptor_f_on_conf_destroy_t
rd_kafka_interceptor_f_on_conf_dup_t
rd_kafka_interceptor_f_on_conf_set_t
rd_kafka_interceptor_f_on_consume_t
rd_kafka_interceptor_f_on_destroy_t
rd_kafka_interceptor_f_on_new_t
rd_kafka_interceptor_f_on_request_sent_t
rd_kafka_interceptor_f_on_response_received_t
rd_kafka_interceptor_f_on_send_t
rd_kafka_interceptor_f_on_thread_exit_t
rd_kafka_interceptor_f_on_thread_start_t
rd_kafka_message_t
rd_kafka_metadata_broker_t
rd_kafka_metadata_partition_t
rd_kafka_metadata_t
rd_kafka_metadata_topic_t
rd_kafka_mock_cluster_t
rd_kafka_mock_request_t
rd_kafka_plugin_f_conf_init_t
rd_kafka_queue_t
rd_kafka_t
rd_kafka_topic_conf_t
rd_kafka_topic_partition_list_t
rd_kafka_topic_partition_t
rd_kafka_topic_result_t
rd_kafka_topic_t
rd_kafka_vu_t
Unions
rd_kafka_vu_s__bindgen_ty_1