List of all items

Structs

• ClientConfig
• KWClient
• KWConsumer
• KWConsumerConf
• KWProducer
• KWProducerConf
• Statistics
• TopicPartitionList
• admin::AdminClient
• admin::AdminOptions
• admin::AlterConfig
• admin::ConfigEntry
• admin::ConfigResource
• admin::NewPartitions
• admin::NewTopic
• bindings::rd_kafka_AclBinding_s
• bindings::rd_kafka_AdminOptions_s
• bindings::rd_kafka_AlterConsumerGroupOffsets_s
• bindings::rd_kafka_AlterUserScramCredentials_result_response_s
• bindings::rd_kafka_ConfigEntry_s
• bindings::rd_kafka_ConfigResource_s
• bindings::rd_kafka_ConsumerGroupDescription_s
• bindings::rd_kafka_ConsumerGroupListing_s
• bindings::rd_kafka_DeleteAcls_result_response_s
• bindings::rd_kafka_DeleteConsumerGroupOffsets_s
• bindings::rd_kafka_DeleteGroup_s
• bindings::rd_kafka_DeleteRecords_s
• bindings::rd_kafka_DeleteTopic_s
• bindings::rd_kafka_ListConsumerGroupOffsets_s
• bindings::rd_kafka_ListConsumerGroupsResult_s
• bindings::rd_kafka_ListOffsetsResultInfo_s
• bindings::rd_kafka_MemberAssignment_s
• bindings::rd_kafka_MemberDescription_s
• bindings::rd_kafka_NewPartitions_s
• bindings::rd_kafka_NewTopic_s
• bindings::rd_kafka_Node_s
• bindings::rd_kafka_ScramCredentialInfo_s
• bindings::rd_kafka_TopicCollection_s
• bindings::rd_kafka_TopicDescription_s
• bindings::rd_kafka_TopicPartitionInfo_s
• bindings::rd_kafka_UserScramCredentialAlteration_s
• bindings::rd_kafka_UserScramCredentialsDescription_s
• bindings::rd_kafka_Uuid_s
• bindings::rd_kafka_acl_result_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_mock_cluster_s
• bindings::rd_kafka_mock_request_s
• 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__bindgen_ty_1
• bindings::rd_kafka_vu_s__bindgen_ty_1__bindgen_ty_2
• client::Client
• client::DefaultClientContext
• client::NativeClient
• client::OAuthToken
• config::ClientConfig
• config::NativeClientConfig
• consumer::BaseConsumer
• consumer::ConsumerGroupMetadata
• consumer::DefaultConsumerContext
• consumer::MessageStream
• consumer::StreamConsumer
• consumer::base_consumer::BaseConsumer
• consumer::base_consumer::Iter
• consumer::base_consumer::PartitionQueue
• consumer::stream_consumer::MessageStream
• consumer::stream_consumer::StreamConsumer
• consumer::stream_consumer::StreamPartitionQueue
• error::RDKafkaError
• groups::GroupInfo
• groups::GroupList
• groups::GroupMemberInfo
• hp_producer::HpProducer
• hp_producer::HpProducerContext
• message::BorrowedHeaders
• message::BorrowedMessage
• message::Header
• message::HeadersIter
• message::OwnedHeaders
• message::OwnedMessage
• metadata::Metadata
• metadata::MetadataBroker
• metadata::MetadataPartition
• metadata::MetadataTopic
• mocking::MockCluster
• producer::BaseProducer
• producer::BaseRecord
• producer::DefaultProducerContext
• producer::DeliveryFuture
• producer::FutureProducer
• producer::FutureRecord
• producer::NoCustomPartitioner
• producer::PurgeConfig
• producer::ThreadedProducer
• producer::base_producer::BaseProducer
• producer::base_producer::BaseRecord
• producer::base_producer::ThreadedProducer
• producer::future_producer::DeliveryFuture
• producer::future_producer::FutureProducer
• producer::future_producer::FutureProducerContext
• producer::future_producer::FutureRecord
• statistics::Broker
• statistics::ConsumerGroup
• statistics::ExactlyOnceSemantics
• statistics::Partition
• statistics::Statistics
• statistics::Topic
• statistics::TopicPartition
• statistics::Window
• topic_partition_list::TopicPartitionList
• topic_partition_list::TopicPartitionListElem
• util::TokioRuntime

Enums

• KWError
• Offset
• Timestamp
• admin::ConfigSource
• admin::OwnedResourceSpecifier
• admin::ResourceSpecifier
• admin::TopicReplication
• bindings::rd_kafka_AclOperation_t
• bindings::rd_kafka_AclPermissionType_t
• bindings::rd_kafka_AlterConfigOpType_t
• bindings::rd_kafka_ConfigSource_t
• bindings::rd_kafka_IsolationLevel_t
• bindings::rd_kafka_OffsetSpec_t
• bindings::rd_kafka_ResourcePatternType_t
• bindings::rd_kafka_ResourceType_t
• bindings::rd_kafka_ScramMechanism_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_consumer_group_state_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
• config::RDKafkaLogLevel
• consumer::CommitMode
• consumer::Rebalance
• consumer::RebalanceProtocol
• error::KafkaError
• error::RDKafkaErrorCode
• message::Timestamp
• mocking::MockCoordinator
• topic_partition_list::Offset
• types::RDKafkaAdminOp
• types::RDKafkaApiKey
• types::RDKafkaConfRes
• types::RDKafkaConfigSource
• types::RDKafkaErrorCode
• types::RDKafkaResourceType
• types::RDKafkaRespErr
• types::RDKafkaType
• util::Timeout

Unions

• bindings::rd_kafka_vu_s__bindgen_ty_1

Traits

• AdminClientExt
• ClientContext
• IntoOpaque
• LogWrapExt
• Message
• OptionExt
• client::ClientContext
• config::FromClientConfig
• config::FromClientConfigAndContext
• consumer::Consumer
• consumer::ConsumerContext
• error::IsError
• log_wrap::LogWrapExt
• message::FromBytes
• message::Headers
• message::Message
• message::ToBytes
• producer::Partitioner
• producer::Producer
• producer::ProducerContext
• util::AsyncRuntime
• util::IntoOpaque

Functions

• bindings::rd_kafka_AclBindingFilter_new
• bindings::rd_kafka_AclBinding_destroy
• bindings::rd_kafka_AclBinding_destroy_array
• bindings::rd_kafka_AclBinding_error
• bindings::rd_kafka_AclBinding_host
• bindings::rd_kafka_AclBinding_name
• bindings::rd_kafka_AclBinding_new
• bindings::rd_kafka_AclBinding_operation
• bindings::rd_kafka_AclBinding_permission_type
• bindings::rd_kafka_AclBinding_principal
• bindings::rd_kafka_AclBinding_resource_pattern_type
• bindings::rd_kafka_AclBinding_restype
• bindings::rd_kafka_AclOperation_name
• bindings::rd_kafka_AclPermissionType_name
• bindings::rd_kafka_AdminOptions_destroy
• bindings::rd_kafka_AdminOptions_new
• bindings::rd_kafka_AdminOptions_set_broker
• bindings::rd_kafka_AdminOptions_set_include_authorized_operations
• bindings::rd_kafka_AdminOptions_set_isolation_level
• bindings::rd_kafka_AdminOptions_set_match_consumer_group_states
• 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_require_stable_offsets
• bindings::rd_kafka_AdminOptions_set_validate_only
• bindings::rd_kafka_AlterConfigs
• bindings::rd_kafka_AlterConfigs_result_resources
• bindings::rd_kafka_AlterConsumerGroupOffsets
• bindings::rd_kafka_AlterConsumerGroupOffsets_destroy
• bindings::rd_kafka_AlterConsumerGroupOffsets_destroy_array
• bindings::rd_kafka_AlterConsumerGroupOffsets_new
• bindings::rd_kafka_AlterConsumerGroupOffsets_result_groups
• bindings::rd_kafka_AlterUserScramCredentials
• bindings::rd_kafka_AlterUserScramCredentials_result_response_error
• bindings::rd_kafka_AlterUserScramCredentials_result_response_user
• bindings::rd_kafka_AlterUserScramCredentials_result_responses
• 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_add_incremental_config
• 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_ConsumerGroupDescription_authorized_operations
• bindings::rd_kafka_ConsumerGroupDescription_coordinator
• bindings::rd_kafka_ConsumerGroupDescription_error
• bindings::rd_kafka_ConsumerGroupDescription_group_id
• bindings::rd_kafka_ConsumerGroupDescription_is_simple_consumer_group
• bindings::rd_kafka_ConsumerGroupDescription_member
• bindings::rd_kafka_ConsumerGroupDescription_member_count
• bindings::rd_kafka_ConsumerGroupDescription_partition_assignor
• bindings::rd_kafka_ConsumerGroupDescription_state
• bindings::rd_kafka_ConsumerGroupListing_group_id
• bindings::rd_kafka_ConsumerGroupListing_is_simple_consumer_group
• bindings::rd_kafka_ConsumerGroupListing_state
• bindings::rd_kafka_CreateAcls
• bindings::rd_kafka_CreateAcls_result_acls
• bindings::rd_kafka_CreatePartitions
• bindings::rd_kafka_CreatePartitions_result_topics
• bindings::rd_kafka_CreateTopics
• bindings::rd_kafka_CreateTopics_result_topics
• bindings::rd_kafka_DeleteAcls
• bindings::rd_kafka_DeleteAcls_result_response_error
• bindings::rd_kafka_DeleteAcls_result_response_matching_acls
• bindings::rd_kafka_DeleteAcls_result_responses
• 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_DescribeAcls
• bindings::rd_kafka_DescribeAcls_result_acls
• bindings::rd_kafka_DescribeCluster
• bindings::rd_kafka_DescribeCluster_result_authorized_operations
• bindings::rd_kafka_DescribeCluster_result_cluster_id
• bindings::rd_kafka_DescribeCluster_result_controller
• bindings::rd_kafka_DescribeCluster_result_nodes
• bindings::rd_kafka_DescribeConfigs
• bindings::rd_kafka_DescribeConfigs_result_resources
• bindings::rd_kafka_DescribeConsumerGroups
• bindings::rd_kafka_DescribeConsumerGroups_result_groups
• bindings::rd_kafka_DescribeTopics
• bindings::rd_kafka_DescribeTopics_result_topics
• bindings::rd_kafka_DescribeUserScramCredentials
• bindings::rd_kafka_DescribeUserScramCredentials_result_descriptions
• bindings::rd_kafka_IncrementalAlterConfigs
• bindings::rd_kafka_IncrementalAlterConfigs_result_resources
• bindings::rd_kafka_ListConsumerGroupOffsets
• bindings::rd_kafka_ListConsumerGroupOffsets_destroy
• bindings::rd_kafka_ListConsumerGroupOffsets_destroy_array
• bindings::rd_kafka_ListConsumerGroupOffsets_new
• bindings::rd_kafka_ListConsumerGroupOffsets_result_groups
• bindings::rd_kafka_ListConsumerGroups
• bindings::rd_kafka_ListConsumerGroups_result_errors
• bindings::rd_kafka_ListConsumerGroups_result_valid
• bindings::rd_kafka_ListOffsets
• bindings::rd_kafka_ListOffsetsResultInfo_timestamp
• bindings::rd_kafka_ListOffsetsResultInfo_topic_partition
• bindings::rd_kafka_ListOffsets_result_infos
• bindings::rd_kafka_MemberAssignment_partitions
• bindings::rd_kafka_MemberDescription_assignment
• bindings::rd_kafka_MemberDescription_client_id
• bindings::rd_kafka_MemberDescription_consumer_id
• bindings::rd_kafka_MemberDescription_group_instance_id
• bindings::rd_kafka_MemberDescription_host
• 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_Node_host
• bindings::rd_kafka_Node_id
• bindings::rd_kafka_Node_port
• bindings::rd_kafka_Node_rack
• bindings::rd_kafka_ResourcePatternType_name
• bindings::rd_kafka_ResourceType_name
• bindings::rd_kafka_ScramCredentialInfo_iterations
• bindings::rd_kafka_ScramCredentialInfo_mechanism
• bindings::rd_kafka_TopicCollection_destroy
• bindings::rd_kafka_TopicCollection_of_topic_names
• bindings::rd_kafka_TopicDescription_authorized_operations
• bindings::rd_kafka_TopicDescription_error
• bindings::rd_kafka_TopicDescription_is_internal
• bindings::rd_kafka_TopicDescription_name
• bindings::rd_kafka_TopicDescription_partitions
• bindings::rd_kafka_TopicDescription_topic_id
• bindings::rd_kafka_TopicPartitionInfo_isr
• bindings::rd_kafka_TopicPartitionInfo_leader
• bindings::rd_kafka_TopicPartitionInfo_partition
• bindings::rd_kafka_TopicPartitionInfo_replicas
• bindings::rd_kafka_UserScramCredentialAlteration_destroy
• bindings::rd_kafka_UserScramCredentialAlteration_destroy_array
• bindings::rd_kafka_UserScramCredentialDeletion_new
• bindings::rd_kafka_UserScramCredentialUpsertion_new
• bindings::rd_kafka_UserScramCredentialsDescription_error
• bindings::rd_kafka_UserScramCredentialsDescription_scramcredentialinfo
• bindings::rd_kafka_UserScramCredentialsDescription_scramcredentialinfo_count
• bindings::rd_kafka_UserScramCredentialsDescription_user
• bindings::rd_kafka_Uuid_base64str
• bindings::rd_kafka_Uuid_copy
• bindings::rd_kafka_Uuid_destroy
• bindings::rd_kafka_Uuid_least_significant_bits
• bindings::rd_kafka_Uuid_most_significant_bits
• bindings::rd_kafka_Uuid_new
• bindings::rd_kafka_abort_transaction
• bindings::rd_kafka_acl_result_error
• 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_enable_sasl_queue
• 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_close_queue
• bindings::rd_kafka_consumer_closed
• 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_group_state_code
• bindings::rd_kafka_consumer_group_state_name
• 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_AlterConsumerGroupOffsets_result
• bindings::rd_kafka_event_AlterUserScramCredentials_result
• bindings::rd_kafka_event_CreateAcls_result
• bindings::rd_kafka_event_CreatePartitions_result
• bindings::rd_kafka_event_CreateTopics_result
• bindings::rd_kafka_event_DeleteAcls_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_DescribeAcls_result
• bindings::rd_kafka_event_DescribeCluster_result
• bindings::rd_kafka_event_DescribeConfigs_result
• bindings::rd_kafka_event_DescribeConsumerGroups_result
• bindings::rd_kafka_event_DescribeTopics_result
• bindings::rd_kafka_event_DescribeUserScramCredentials_result
• bindings::rd_kafka_event_IncrementalAlterConfigs_result
• bindings::rd_kafka_event_ListConsumerGroupOffsets_result
• bindings::rd_kafka_event_ListConsumerGroups_result
• bindings::rd_kafka_event_ListOffsets_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_handle_mock_cluster
• 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_broker_state_change
• 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_leader_epoch
• 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_mock_broker_error_stack_cnt
• bindings::rd_kafka_mock_broker_push_request_error_rtts
• bindings::rd_kafka_mock_broker_set_down
• bindings::rd_kafka_mock_broker_set_rack
• bindings::rd_kafka_mock_broker_set_rtt
• bindings::rd_kafka_mock_broker_set_up
• bindings::rd_kafka_mock_clear_request_errors
• bindings::rd_kafka_mock_clear_requests
• bindings::rd_kafka_mock_cluster_bootstraps
• bindings::rd_kafka_mock_cluster_destroy
• bindings::rd_kafka_mock_cluster_handle
• bindings::rd_kafka_mock_cluster_new
• bindings::rd_kafka_mock_coordinator_set
• bindings::rd_kafka_mock_get_requests
• bindings::rd_kafka_mock_partition_set_follower
• bindings::rd_kafka_mock_partition_set_follower_wmarks
• bindings::rd_kafka_mock_partition_set_leader
• bindings::rd_kafka_mock_push_request_errors
• bindings::rd_kafka_mock_push_request_errors_array
• bindings::rd_kafka_mock_request_api_key
• bindings::rd_kafka_mock_request_destroy
• bindings::rd_kafka_mock_request_id
• bindings::rd_kafka_mock_request_timestamp
• bindings::rd_kafka_mock_set_apiversion
• bindings::rd_kafka_mock_start_request_tracking
• bindings::rd_kafka_mock_stop_request_tracking
• bindings::rd_kafka_mock_topic_create
• bindings::rd_kafka_mock_topic_set_error
• 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_offset_store_message
• 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_get_sasl
• 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_sasl_background_callbacks_enable
• bindings::rd_kafka_sasl_set_credentials
• 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_get_leader_epoch
• 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_partition_set_leader_epoch
• 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
• util::cstr_to_owned
• util::current_time_millis
• util::get_rdkafka_version
• util::millis_to_epoch
• wrap_conf::debug

Type Aliases

• Brokers
• GroupID
• KWResult
• TopicName
• admin::AlterConfigsResult
• admin::ConfigResourceResult
• admin::GroupResult
• admin::PartitionAssignment
• admin::TopicResult
• bindings::rd_kafka_AclBindingFilter_t
• bindings::rd_kafka_AclBinding_t
• bindings::rd_kafka_AdminOptions_t
• bindings::rd_kafka_AlterConfigs_result_t
• bindings::rd_kafka_AlterConsumerGroupOffsets_result_t
• bindings::rd_kafka_AlterConsumerGroupOffsets_t
• bindings::rd_kafka_AlterUserScramCredentials_result_response_t
• bindings::rd_kafka_AlterUserScramCredentials_result_t
• bindings::rd_kafka_ConfigEntry_t
• bindings::rd_kafka_ConfigResource_t
• bindings::rd_kafka_ConsumerGroupDescription_t
• bindings::rd_kafka_ConsumerGroupListing_t
• bindings::rd_kafka_CreateAcls_result_t
• bindings::rd_kafka_CreatePartitions_result_t
• bindings::rd_kafka_CreateTopics_result_t
• bindings::rd_kafka_DeleteAcls_result_response_t
• bindings::rd_kafka_DeleteAcls_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_DescribeAcls_result_t
• bindings::rd_kafka_DescribeCluster_result_t
• bindings::rd_kafka_DescribeConfigs_result_t
• bindings::rd_kafka_DescribeConsumerGroups_result_t
• bindings::rd_kafka_DescribeTopics_result_t
• bindings::rd_kafka_DescribeUserScramCredentials_result_t
• bindings::rd_kafka_IncrementalAlterConfigs_result_t
• bindings::rd_kafka_ListConsumerGroupOffsets_result_t
• bindings::rd_kafka_ListConsumerGroupOffsets_t
• bindings::rd_kafka_ListConsumerGroupsResult_t
• bindings::rd_kafka_ListConsumerGroups_result_t
• bindings::rd_kafka_ListOffsetsResultInfo_t
• bindings::rd_kafka_ListOffsets_result_t
• bindings::rd_kafka_MemberAssignment_t
• bindings::rd_kafka_MemberDescription_t
• bindings::rd_kafka_NewPartitions_t
• bindings::rd_kafka_NewTopic_t
• bindings::rd_kafka_Node_t
• bindings::rd_kafka_ScramCredentialInfo_t
• bindings::rd_kafka_TopicCollection_t
• bindings::rd_kafka_TopicDescription_t
• bindings::rd_kafka_TopicPartitionInfo_t
• bindings::rd_kafka_UserScramCredentialAlteration_t
• bindings::rd_kafka_UserScramCredentialsDescription_t
• bindings::rd_kafka_Uuid_t
• bindings::rd_kafka_acl_result_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_broker_state_change_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_mock_cluster_t
• bindings::rd_kafka_mock_request_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
• error::KafkaResult
• message::DeliveryResult
• producer::DeliveryResult
• producer::base_producer::DeliveryResult
• producer::future_producer::OwnedDeliveryResult
• types::RDKafka
• types::RDKafkaAdminOptions
• types::RDKafkaConf
• types::RDKafkaConfigResource
• types::RDKafkaConsumerGroupMetadata
• types::RDKafkaDeleteGroup
• types::RDKafkaDeleteTopic
• types::RDKafkaEvent
• types::RDKafkaGroupInfo
• types::RDKafkaGroupList
• types::RDKafkaGroupMemberInfo
• types::RDKafkaGroupResult
• types::RDKafkaHeaders
• types::RDKafkaMessage
• types::RDKafkaMetadata
• types::RDKafkaMetadataBroker
• types::RDKafkaMetadataPartition
• types::RDKafkaMetadataTopic
• types::RDKafkaMockCluster
• types::RDKafkaNewPartitions
• types::RDKafkaNewTopic
• types::RDKafkaQueue
• types::RDKafkaState
• types::RDKafkaTopic
• types::RDKafkaTopicConf
• types::RDKafkaTopicPartition
• types::RDKafkaTopicPartitionList
• types::RDKafkaTopicResult
• util::DefaultRuntime

Constants

• bindings::RD_KAFKA_DEBUG_CONTEXTS
• bindings::RD_KAFKA_DESTROY_F_NO_CONSUMER_CLOSE
• bindings::RD_KAFKA_EVENT_ALTERCONFIGS_RESULT
• bindings::RD_KAFKA_EVENT_ALTERCONSUMERGROUPOFFSETS_RESULT
• bindings::RD_KAFKA_EVENT_ALTERUSERSCRAMCREDENTIALS_RESULT
• bindings::RD_KAFKA_EVENT_BACKGROUND
• bindings::RD_KAFKA_EVENT_CREATEACLS_RESULT
• bindings::RD_KAFKA_EVENT_CREATEPARTITIONS_RESULT
• bindings::RD_KAFKA_EVENT_CREATETOPICS_RESULT
• bindings::RD_KAFKA_EVENT_DELETEACLS_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_DESCRIBEACLS_RESULT
• bindings::RD_KAFKA_EVENT_DESCRIBECLUSTER_RESULT
• bindings::RD_KAFKA_EVENT_DESCRIBECONFIGS_RESULT
• bindings::RD_KAFKA_EVENT_DESCRIBECONSUMERGROUPS_RESULT
• bindings::RD_KAFKA_EVENT_DESCRIBETOPICS_RESULT
• bindings::RD_KAFKA_EVENT_DESCRIBEUSERSCRAMCREDENTIALS_RESULT
• bindings::RD_KAFKA_EVENT_DR
• bindings::RD_KAFKA_EVENT_ERROR
• bindings::RD_KAFKA_EVENT_FETCH
• bindings::RD_KAFKA_EVENT_INCREMENTALALTERCONFIGS_RESULT
• bindings::RD_KAFKA_EVENT_LISTCONSUMERGROUPOFFSETS_RESULT
• bindings::RD_KAFKA_EVENT_LISTCONSUMERGROUPS_RESULT
• bindings::RD_KAFKA_EVENT_LISTOFFSETS_RESULT
• 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
• configuration::all::BOOTSTRAP_SERVERS
• configuration::consumer::GROUP_ID
• producer::PARTITION_UA