List of all items
Structs
- app::Callysto
- config::Config
- config::KafkaConfig
- kafka::cadmin::CAdminClient
- kafka::cconsumer::CConsumer
- kafka::cconsumer::CStream
- kafka::contexts::CConsumerContext
- kafka::contexts::CStatistics
- kafka::cproducer::CProducer
- kafka::ctopic::CTP
- kafka::ctopic::CTopic
- kafka::runtime::NucleiRuntime
- prelude::CWebRequest
- prelude::CWebResponse
- prelude::ClientConfig
- prelude::Statistics
- prelude::TopicPartitionList
- prelude::admin::AdminClient
- prelude::admin::AdminOptions
- prelude::admin::AlterConfig
- prelude::admin::ConfigEntry
- prelude::admin::ConfigResource
- prelude::admin::NewPartitions
- prelude::admin::NewTopic
- prelude::bindings::rd_kafka_AclBinding_s
- prelude::bindings::rd_kafka_AdminOptions_s
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets_s
- prelude::bindings::rd_kafka_AlterUserScramCredentials_result_response_s
- prelude::bindings::rd_kafka_ConfigEntry_s
- prelude::bindings::rd_kafka_ConfigResource_s
- prelude::bindings::rd_kafka_ConsumerGroupDescription_s
- prelude::bindings::rd_kafka_ConsumerGroupListing_s
- prelude::bindings::rd_kafka_DeleteAcls_result_response_s
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets_s
- prelude::bindings::rd_kafka_DeleteGroup_s
- prelude::bindings::rd_kafka_DeleteRecords_s
- prelude::bindings::rd_kafka_DeleteTopic_s
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets_s
- prelude::bindings::rd_kafka_ListConsumerGroupsResult_s
- prelude::bindings::rd_kafka_ListOffsetsResultInfo_s
- prelude::bindings::rd_kafka_MemberAssignment_s
- prelude::bindings::rd_kafka_MemberDescription_s
- prelude::bindings::rd_kafka_NewPartitions_s
- prelude::bindings::rd_kafka_NewTopic_s
- prelude::bindings::rd_kafka_Node_s
- prelude::bindings::rd_kafka_ScramCredentialInfo_s
- prelude::bindings::rd_kafka_TopicCollection_s
- prelude::bindings::rd_kafka_TopicDescription_s
- prelude::bindings::rd_kafka_TopicPartitionInfo_s
- prelude::bindings::rd_kafka_UserScramCredentialAlteration_s
- prelude::bindings::rd_kafka_UserScramCredentialsDescription_s
- prelude::bindings::rd_kafka_Uuid_s
- prelude::bindings::rd_kafka_acl_result_s
- prelude::bindings::rd_kafka_conf_s
- prelude::bindings::rd_kafka_consumer_group_metadata_s
- prelude::bindings::rd_kafka_err_desc
- prelude::bindings::rd_kafka_error_s
- prelude::bindings::rd_kafka_group_info
- prelude::bindings::rd_kafka_group_list
- prelude::bindings::rd_kafka_group_member_info
- prelude::bindings::rd_kafka_group_result_s
- prelude::bindings::rd_kafka_headers_s
- prelude::bindings::rd_kafka_message_s
- prelude::bindings::rd_kafka_metadata
- prelude::bindings::rd_kafka_metadata_broker
- prelude::bindings::rd_kafka_metadata_partition
- prelude::bindings::rd_kafka_metadata_topic
- prelude::bindings::rd_kafka_mock_cluster_s
- prelude::bindings::rd_kafka_mock_request_s
- prelude::bindings::rd_kafka_op_s
- prelude::bindings::rd_kafka_queue_s
- prelude::bindings::rd_kafka_s
- prelude::bindings::rd_kafka_topic_conf_s
- prelude::bindings::rd_kafka_topic_partition_list_s
- prelude::bindings::rd_kafka_topic_partition_s
- prelude::bindings::rd_kafka_topic_result_s
- prelude::bindings::rd_kafka_topic_s
- prelude::bindings::rd_kafka_vu_s
- prelude::bindings::rd_kafka_vu_s__bindgen_ty_1__bindgen_ty_1
- prelude::bindings::rd_kafka_vu_s__bindgen_ty_1__bindgen_ty_2
- prelude::client::Client
- prelude::client::DefaultClientContext
- prelude::client::NativeClient
- prelude::client::OAuthToken
- prelude::config::ClientConfig
- prelude::config::NativeClientConfig
- prelude::consumer::BaseConsumer
- prelude::consumer::ConsumerGroupMetadata
- prelude::consumer::DefaultConsumerContext
- prelude::consumer::MessageStream
- prelude::consumer::StreamConsumer
- prelude::consumer::base_consumer::BaseConsumer
- prelude::consumer::base_consumer::Iter
- prelude::consumer::base_consumer::PartitionQueue
- prelude::consumer::stream_consumer::MessageStream
- prelude::consumer::stream_consumer::StreamConsumer
- prelude::consumer::stream_consumer::StreamPartitionQueue
- prelude::error::RDKafkaError
- prelude::groups::GroupInfo
- prelude::groups::GroupList
- prelude::groups::GroupMemberInfo
- prelude::message::BorrowedHeaders
- prelude::message::BorrowedMessage
- prelude::message::Header
- prelude::message::HeadersIter
- prelude::message::OwnedHeaders
- prelude::message::OwnedMessage
- prelude::metadata::Metadata
- prelude::metadata::MetadataBroker
- prelude::metadata::MetadataPartition
- prelude::metadata::MetadataTopic
- prelude::mocking::MockCluster
- prelude::producer::BaseProducer
- prelude::producer::BaseRecord
- prelude::producer::DefaultProducerContext
- prelude::producer::DeliveryFuture
- prelude::producer::FutureProducer
- prelude::producer::FutureRecord
- prelude::producer::NoCustomPartitioner
- prelude::producer::PurgeConfig
- prelude::producer::ThreadedProducer
- prelude::producer::base_producer::BaseProducer
- prelude::producer::base_producer::BaseRecord
- prelude::producer::base_producer::ThreadedProducer
- prelude::producer::future_producer::DeliveryFuture
- prelude::producer::future_producer::FutureProducer
- prelude::producer::future_producer::FutureProducerContext
- prelude::producer::future_producer::FutureRecord
- prelude::statistics::Broker
- prelude::statistics::ConsumerGroup
- prelude::statistics::ExactlyOnceSemantics
- prelude::statistics::Partition
- prelude::statistics::Statistics
- prelude::statistics::Topic
- prelude::statistics::TopicPartition
- prelude::statistics::Window
- prelude::topic_partition_list::TopicPartitionList
- prelude::topic_partition_list::TopicPartitionListElem
- sinks::elasticsearch::CElasticSearchDocument
- sinks::elasticsearch::CElasticSearchSink
- sinks::postgres::CPostgresRow
- sinks::postgres::CPostgresSink
- types::agent::CAgent
- types::context::Context
- types::cronjob::CronJob
- types::flows::CFlow
- types::flows::CSource
- types::route::Route
- types::service::CService
- types::table::CTable
- types::table_agent::CTableAgent
- types::task::CTask
- types::timer::CTimer
Enums
- errors::CallystoError
- kafka::enums::EndpointIdentificationAlgorithm
- kafka::enums::IsolationLevel
- kafka::enums::OffsetReset
- kafka::enums::PartitionAssignment
- kafka::enums::ProcessingGuarantee
- kafka::enums::SaslMechanism
- kafka::enums::SecurityProtocol
- prelude::Offset
- prelude::Timestamp
- prelude::admin::ConfigSource
- prelude::admin::OwnedResourceSpecifier
- prelude::admin::ResourceSpecifier
- prelude::admin::TopicReplication
- prelude::bindings::rd_kafka_AclOperation_t
- prelude::bindings::rd_kafka_AclPermissionType_t
- prelude::bindings::rd_kafka_AlterConfigOpType_t
- prelude::bindings::rd_kafka_ConfigSource_t
- prelude::bindings::rd_kafka_IsolationLevel_t
- prelude::bindings::rd_kafka_OffsetSpec_t
- prelude::bindings::rd_kafka_ResourcePatternType_t
- prelude::bindings::rd_kafka_ResourceType_t
- prelude::bindings::rd_kafka_ScramMechanism_t
- prelude::bindings::rd_kafka_admin_op_t
- prelude::bindings::rd_kafka_cert_enc_t
- prelude::bindings::rd_kafka_cert_type_t
- prelude::bindings::rd_kafka_conf_res_t
- prelude::bindings::rd_kafka_consumer_group_state_t
- prelude::bindings::rd_kafka_msg_status_t
- prelude::bindings::rd_kafka_resp_err_t
- prelude::bindings::rd_kafka_thread_type_t
- prelude::bindings::rd_kafka_timestamp_type_t
- prelude::bindings::rd_kafka_type_t
- prelude::bindings::rd_kafka_vtype_t
- prelude::config::RDKafkaLogLevel
- prelude::consumer::CommitMode
- prelude::consumer::Rebalance
- prelude::consumer::RebalanceProtocol
- prelude::error::KafkaError
- prelude::error::RDKafkaErrorCode
- prelude::message::Timestamp
- prelude::mocking::MockCoordinator
- prelude::topic_partition_list::Offset
- prelude::types::RDKafkaAdminOp
- prelude::types::RDKafkaApiKey
- prelude::types::RDKafkaConfRes
- prelude::types::RDKafkaConfigSource
- prelude::types::RDKafkaErrorCode
- prelude::types::RDKafkaResourceType
- prelude::types::RDKafkaRespErr
- prelude::types::RDKafkaType
- prelude::util::Timeout
- types::service::ServiceState
Unions
Traits
- prelude::ClientContext
- prelude::IntoOpaque
- prelude::Message
- prelude::client::ClientContext
- prelude::config::FromClientConfig
- prelude::config::FromClientConfigAndContext
- prelude::consumer::Consumer
- prelude::consumer::ConsumerContext
- prelude::error::IsError
- prelude::message::FromBytes
- prelude::message::Headers
- prelude::message::Message
- prelude::message::ToBytes
- prelude::producer::Partitioner
- prelude::producer::Producer
- prelude::producer::ProducerContext
- prelude::util::AsyncRuntime
- prelude::util::IntoOpaque
- types::agent::Agent
- types::collection::Collection
- types::flows::Flow
- types::route::Router
- types::service::Service
- types::table_agent::TableAgent
- types::task::Task
Functions
- prelude::bindings::rd_kafka_AclBindingFilter_new
- prelude::bindings::rd_kafka_AclBinding_destroy
- prelude::bindings::rd_kafka_AclBinding_destroy_array
- prelude::bindings::rd_kafka_AclBinding_error
- prelude::bindings::rd_kafka_AclBinding_host
- prelude::bindings::rd_kafka_AclBinding_name
- prelude::bindings::rd_kafka_AclBinding_new
- prelude::bindings::rd_kafka_AclBinding_operation
- prelude::bindings::rd_kafka_AclBinding_permission_type
- prelude::bindings::rd_kafka_AclBinding_principal
- prelude::bindings::rd_kafka_AclBinding_resource_pattern_type
- prelude::bindings::rd_kafka_AclBinding_restype
- prelude::bindings::rd_kafka_AclOperation_name
- prelude::bindings::rd_kafka_AclPermissionType_name
- prelude::bindings::rd_kafka_AdminOptions_destroy
- prelude::bindings::rd_kafka_AdminOptions_new
- prelude::bindings::rd_kafka_AdminOptions_set_broker
- prelude::bindings::rd_kafka_AdminOptions_set_include_authorized_operations
- prelude::bindings::rd_kafka_AdminOptions_set_isolation_level
- prelude::bindings::rd_kafka_AdminOptions_set_match_consumer_group_states
- prelude::bindings::rd_kafka_AdminOptions_set_opaque
- prelude::bindings::rd_kafka_AdminOptions_set_operation_timeout
- prelude::bindings::rd_kafka_AdminOptions_set_request_timeout
- prelude::bindings::rd_kafka_AdminOptions_set_require_stable_offsets
- prelude::bindings::rd_kafka_AdminOptions_set_validate_only
- prelude::bindings::rd_kafka_AlterConfigs
- prelude::bindings::rd_kafka_AlterConfigs_result_resources
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets_destroy
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets_destroy_array
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets_new
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets_result_groups
- prelude::bindings::rd_kafka_AlterUserScramCredentials
- prelude::bindings::rd_kafka_AlterUserScramCredentials_result_response_error
- prelude::bindings::rd_kafka_AlterUserScramCredentials_result_response_user
- prelude::bindings::rd_kafka_AlterUserScramCredentials_result_responses
- prelude::bindings::rd_kafka_ConfigEntry_is_default
- prelude::bindings::rd_kafka_ConfigEntry_is_read_only
- prelude::bindings::rd_kafka_ConfigEntry_is_sensitive
- prelude::bindings::rd_kafka_ConfigEntry_is_synonym
- prelude::bindings::rd_kafka_ConfigEntry_name
- prelude::bindings::rd_kafka_ConfigEntry_source
- prelude::bindings::rd_kafka_ConfigEntry_synonyms
- prelude::bindings::rd_kafka_ConfigEntry_value
- prelude::bindings::rd_kafka_ConfigResource_add_incremental_config
- prelude::bindings::rd_kafka_ConfigResource_configs
- prelude::bindings::rd_kafka_ConfigResource_destroy
- prelude::bindings::rd_kafka_ConfigResource_destroy_array
- prelude::bindings::rd_kafka_ConfigResource_error
- prelude::bindings::rd_kafka_ConfigResource_error_string
- prelude::bindings::rd_kafka_ConfigResource_name
- prelude::bindings::rd_kafka_ConfigResource_new
- prelude::bindings::rd_kafka_ConfigResource_set_config
- prelude::bindings::rd_kafka_ConfigResource_type
- prelude::bindings::rd_kafka_ConfigSource_name
- prelude::bindings::rd_kafka_ConsumerGroupDescription_authorized_operations
- prelude::bindings::rd_kafka_ConsumerGroupDescription_coordinator
- prelude::bindings::rd_kafka_ConsumerGroupDescription_error
- prelude::bindings::rd_kafka_ConsumerGroupDescription_group_id
- prelude::bindings::rd_kafka_ConsumerGroupDescription_is_simple_consumer_group
- prelude::bindings::rd_kafka_ConsumerGroupDescription_member
- prelude::bindings::rd_kafka_ConsumerGroupDescription_member_count
- prelude::bindings::rd_kafka_ConsumerGroupDescription_partition_assignor
- prelude::bindings::rd_kafka_ConsumerGroupDescription_state
- prelude::bindings::rd_kafka_ConsumerGroupListing_group_id
- prelude::bindings::rd_kafka_ConsumerGroupListing_is_simple_consumer_group
- prelude::bindings::rd_kafka_ConsumerGroupListing_state
- prelude::bindings::rd_kafka_CreateAcls
- prelude::bindings::rd_kafka_CreateAcls_result_acls
- prelude::bindings::rd_kafka_CreatePartitions
- prelude::bindings::rd_kafka_CreatePartitions_result_topics
- prelude::bindings::rd_kafka_CreateTopics
- prelude::bindings::rd_kafka_CreateTopics_result_topics
- prelude::bindings::rd_kafka_DeleteAcls
- prelude::bindings::rd_kafka_DeleteAcls_result_response_error
- prelude::bindings::rd_kafka_DeleteAcls_result_response_matching_acls
- prelude::bindings::rd_kafka_DeleteAcls_result_responses
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets_destroy
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets_destroy_array
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets_new
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets_result_groups
- prelude::bindings::rd_kafka_DeleteGroup_destroy
- prelude::bindings::rd_kafka_DeleteGroup_destroy_array
- prelude::bindings::rd_kafka_DeleteGroup_new
- prelude::bindings::rd_kafka_DeleteGroups
- prelude::bindings::rd_kafka_DeleteGroups_result_groups
- prelude::bindings::rd_kafka_DeleteRecords
- prelude::bindings::rd_kafka_DeleteRecords_destroy
- prelude::bindings::rd_kafka_DeleteRecords_destroy_array
- prelude::bindings::rd_kafka_DeleteRecords_new
- prelude::bindings::rd_kafka_DeleteRecords_result_offsets
- prelude::bindings::rd_kafka_DeleteTopic_destroy
- prelude::bindings::rd_kafka_DeleteTopic_destroy_array
- prelude::bindings::rd_kafka_DeleteTopic_new
- prelude::bindings::rd_kafka_DeleteTopics
- prelude::bindings::rd_kafka_DeleteTopics_result_topics
- prelude::bindings::rd_kafka_DescribeAcls
- prelude::bindings::rd_kafka_DescribeAcls_result_acls
- prelude::bindings::rd_kafka_DescribeCluster
- prelude::bindings::rd_kafka_DescribeCluster_result_authorized_operations
- prelude::bindings::rd_kafka_DescribeCluster_result_cluster_id
- prelude::bindings::rd_kafka_DescribeCluster_result_controller
- prelude::bindings::rd_kafka_DescribeCluster_result_nodes
- prelude::bindings::rd_kafka_DescribeConfigs
- prelude::bindings::rd_kafka_DescribeConfigs_result_resources
- prelude::bindings::rd_kafka_DescribeConsumerGroups
- prelude::bindings::rd_kafka_DescribeConsumerGroups_result_groups
- prelude::bindings::rd_kafka_DescribeTopics
- prelude::bindings::rd_kafka_DescribeTopics_result_topics
- prelude::bindings::rd_kafka_DescribeUserScramCredentials
- prelude::bindings::rd_kafka_DescribeUserScramCredentials_result_descriptions
- prelude::bindings::rd_kafka_IncrementalAlterConfigs
- prelude::bindings::rd_kafka_IncrementalAlterConfigs_result_resources
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets_destroy
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets_destroy_array
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets_new
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets_result_groups
- prelude::bindings::rd_kafka_ListConsumerGroups
- prelude::bindings::rd_kafka_ListConsumerGroups_result_errors
- prelude::bindings::rd_kafka_ListConsumerGroups_result_valid
- prelude::bindings::rd_kafka_ListOffsets
- prelude::bindings::rd_kafka_ListOffsetsResultInfo_timestamp
- prelude::bindings::rd_kafka_ListOffsetsResultInfo_topic_partition
- prelude::bindings::rd_kafka_ListOffsets_result_infos
- prelude::bindings::rd_kafka_MemberAssignment_partitions
- prelude::bindings::rd_kafka_MemberDescription_assignment
- prelude::bindings::rd_kafka_MemberDescription_client_id
- prelude::bindings::rd_kafka_MemberDescription_consumer_id
- prelude::bindings::rd_kafka_MemberDescription_group_instance_id
- prelude::bindings::rd_kafka_MemberDescription_host
- prelude::bindings::rd_kafka_NewPartitions_destroy
- prelude::bindings::rd_kafka_NewPartitions_destroy_array
- prelude::bindings::rd_kafka_NewPartitions_new
- prelude::bindings::rd_kafka_NewPartitions_set_replica_assignment
- prelude::bindings::rd_kafka_NewTopic_destroy
- prelude::bindings::rd_kafka_NewTopic_destroy_array
- prelude::bindings::rd_kafka_NewTopic_new
- prelude::bindings::rd_kafka_NewTopic_set_config
- prelude::bindings::rd_kafka_NewTopic_set_replica_assignment
- prelude::bindings::rd_kafka_Node_host
- prelude::bindings::rd_kafka_Node_id
- prelude::bindings::rd_kafka_Node_port
- prelude::bindings::rd_kafka_Node_rack
- prelude::bindings::rd_kafka_ResourcePatternType_name
- prelude::bindings::rd_kafka_ResourceType_name
- prelude::bindings::rd_kafka_ScramCredentialInfo_iterations
- prelude::bindings::rd_kafka_ScramCredentialInfo_mechanism
- prelude::bindings::rd_kafka_TopicCollection_destroy
- prelude::bindings::rd_kafka_TopicCollection_of_topic_names
- prelude::bindings::rd_kafka_TopicDescription_authorized_operations
- prelude::bindings::rd_kafka_TopicDescription_error
- prelude::bindings::rd_kafka_TopicDescription_is_internal
- prelude::bindings::rd_kafka_TopicDescription_name
- prelude::bindings::rd_kafka_TopicDescription_partitions
- prelude::bindings::rd_kafka_TopicDescription_topic_id
- prelude::bindings::rd_kafka_TopicPartitionInfo_isr
- prelude::bindings::rd_kafka_TopicPartitionInfo_leader
- prelude::bindings::rd_kafka_TopicPartitionInfo_partition
- prelude::bindings::rd_kafka_TopicPartitionInfo_replicas
- prelude::bindings::rd_kafka_UserScramCredentialAlteration_destroy
- prelude::bindings::rd_kafka_UserScramCredentialAlteration_destroy_array
- prelude::bindings::rd_kafka_UserScramCredentialDeletion_new
- prelude::bindings::rd_kafka_UserScramCredentialUpsertion_new
- prelude::bindings::rd_kafka_UserScramCredentialsDescription_error
- prelude::bindings::rd_kafka_UserScramCredentialsDescription_scramcredentialinfo
- prelude::bindings::rd_kafka_UserScramCredentialsDescription_scramcredentialinfo_count
- prelude::bindings::rd_kafka_UserScramCredentialsDescription_user
- prelude::bindings::rd_kafka_Uuid_base64str
- prelude::bindings::rd_kafka_Uuid_copy
- prelude::bindings::rd_kafka_Uuid_destroy
- prelude::bindings::rd_kafka_Uuid_least_significant_bits
- prelude::bindings::rd_kafka_Uuid_most_significant_bits
- prelude::bindings::rd_kafka_Uuid_new
- prelude::bindings::rd_kafka_abort_transaction
- prelude::bindings::rd_kafka_acl_result_error
- prelude::bindings::rd_kafka_assign
- prelude::bindings::rd_kafka_assignment
- prelude::bindings::rd_kafka_assignment_lost
- prelude::bindings::rd_kafka_begin_transaction
- prelude::bindings::rd_kafka_brokers_add
- prelude::bindings::rd_kafka_clusterid
- prelude::bindings::rd_kafka_commit
- prelude::bindings::rd_kafka_commit_message
- prelude::bindings::rd_kafka_commit_queue
- prelude::bindings::rd_kafka_commit_transaction
- prelude::bindings::rd_kafka_committed
- prelude::bindings::rd_kafka_conf
- prelude::bindings::rd_kafka_conf_destroy
- prelude::bindings::rd_kafka_conf_dump
- prelude::bindings::rd_kafka_conf_dump_free
- prelude::bindings::rd_kafka_conf_dup
- prelude::bindings::rd_kafka_conf_dup_filter
- prelude::bindings::rd_kafka_conf_enable_sasl_queue
- prelude::bindings::rd_kafka_conf_get
- prelude::bindings::rd_kafka_conf_get_default_topic_conf
- prelude::bindings::rd_kafka_conf_interceptor_add_on_conf_destroy
- prelude::bindings::rd_kafka_conf_interceptor_add_on_conf_dup
- prelude::bindings::rd_kafka_conf_interceptor_add_on_conf_set
- prelude::bindings::rd_kafka_conf_interceptor_add_on_new
- prelude::bindings::rd_kafka_conf_new
- prelude::bindings::rd_kafka_conf_properties_show
- prelude::bindings::rd_kafka_conf_set
- prelude::bindings::rd_kafka_conf_set_background_event_cb
- prelude::bindings::rd_kafka_conf_set_closesocket_cb
- prelude::bindings::rd_kafka_conf_set_connect_cb
- prelude::bindings::rd_kafka_conf_set_consume_cb
- prelude::bindings::rd_kafka_conf_set_default_topic_conf
- prelude::bindings::rd_kafka_conf_set_dr_cb
- prelude::bindings::rd_kafka_conf_set_dr_msg_cb
- prelude::bindings::rd_kafka_conf_set_engine_callback_data
- prelude::bindings::rd_kafka_conf_set_error_cb
- prelude::bindings::rd_kafka_conf_set_events
- prelude::bindings::rd_kafka_conf_set_log_cb
- prelude::bindings::rd_kafka_conf_set_oauthbearer_token_refresh_cb
- prelude::bindings::rd_kafka_conf_set_offset_commit_cb
- prelude::bindings::rd_kafka_conf_set_opaque
- prelude::bindings::rd_kafka_conf_set_rebalance_cb
- prelude::bindings::rd_kafka_conf_set_socket_cb
- prelude::bindings::rd_kafka_conf_set_ssl_cert
- prelude::bindings::rd_kafka_conf_set_ssl_cert_verify_cb
- prelude::bindings::rd_kafka_conf_set_stats_cb
- prelude::bindings::rd_kafka_conf_set_throttle_cb
- prelude::bindings::rd_kafka_consume
- prelude::bindings::rd_kafka_consume_batch
- prelude::bindings::rd_kafka_consume_batch_queue
- prelude::bindings::rd_kafka_consume_callback
- prelude::bindings::rd_kafka_consume_callback_queue
- prelude::bindings::rd_kafka_consume_queue
- prelude::bindings::rd_kafka_consume_start
- prelude::bindings::rd_kafka_consume_start_queue
- prelude::bindings::rd_kafka_consume_stop
- prelude::bindings::rd_kafka_consumer_close
- prelude::bindings::rd_kafka_consumer_close_queue
- prelude::bindings::rd_kafka_consumer_closed
- prelude::bindings::rd_kafka_consumer_group_metadata
- prelude::bindings::rd_kafka_consumer_group_metadata_destroy
- prelude::bindings::rd_kafka_consumer_group_metadata_new
- prelude::bindings::rd_kafka_consumer_group_metadata_new_with_genid
- prelude::bindings::rd_kafka_consumer_group_metadata_read
- prelude::bindings::rd_kafka_consumer_group_metadata_write
- prelude::bindings::rd_kafka_consumer_group_state_code
- prelude::bindings::rd_kafka_consumer_group_state_name
- prelude::bindings::rd_kafka_consumer_poll
- prelude::bindings::rd_kafka_controllerid
- prelude::bindings::rd_kafka_default_topic_conf_dup
- prelude::bindings::rd_kafka_destroy
- prelude::bindings::rd_kafka_destroy_flags
- prelude::bindings::rd_kafka_dump
- prelude::bindings::rd_kafka_err2name
- prelude::bindings::rd_kafka_err2str
- prelude::bindings::rd_kafka_errno
- prelude::bindings::rd_kafka_errno2err
- prelude::bindings::rd_kafka_error_code
- prelude::bindings::rd_kafka_error_destroy
- prelude::bindings::rd_kafka_error_is_fatal
- prelude::bindings::rd_kafka_error_is_retriable
- prelude::bindings::rd_kafka_error_name
- prelude::bindings::rd_kafka_error_new
- prelude::bindings::rd_kafka_error_string
- prelude::bindings::rd_kafka_error_txn_requires_abort
- prelude::bindings::rd_kafka_event_AlterConfigs_result
- prelude::bindings::rd_kafka_event_AlterConsumerGroupOffsets_result
- prelude::bindings::rd_kafka_event_AlterUserScramCredentials_result
- prelude::bindings::rd_kafka_event_CreateAcls_result
- prelude::bindings::rd_kafka_event_CreatePartitions_result
- prelude::bindings::rd_kafka_event_CreateTopics_result
- prelude::bindings::rd_kafka_event_DeleteAcls_result
- prelude::bindings::rd_kafka_event_DeleteConsumerGroupOffsets_result
- prelude::bindings::rd_kafka_event_DeleteGroups_result
- prelude::bindings::rd_kafka_event_DeleteRecords_result
- prelude::bindings::rd_kafka_event_DeleteTopics_result
- prelude::bindings::rd_kafka_event_DescribeAcls_result
- prelude::bindings::rd_kafka_event_DescribeCluster_result
- prelude::bindings::rd_kafka_event_DescribeConfigs_result
- prelude::bindings::rd_kafka_event_DescribeConsumerGroups_result
- prelude::bindings::rd_kafka_event_DescribeTopics_result
- prelude::bindings::rd_kafka_event_DescribeUserScramCredentials_result
- prelude::bindings::rd_kafka_event_IncrementalAlterConfigs_result
- prelude::bindings::rd_kafka_event_ListConsumerGroupOffsets_result
- prelude::bindings::rd_kafka_event_ListConsumerGroups_result
- prelude::bindings::rd_kafka_event_ListOffsets_result
- prelude::bindings::rd_kafka_event_config_string
- prelude::bindings::rd_kafka_event_debug_contexts
- prelude::bindings::rd_kafka_event_destroy
- prelude::bindings::rd_kafka_event_error
- prelude::bindings::rd_kafka_event_error_is_fatal
- prelude::bindings::rd_kafka_event_error_string
- prelude::bindings::rd_kafka_event_log
- prelude::bindings::rd_kafka_event_message_array
- prelude::bindings::rd_kafka_event_message_count
- prelude::bindings::rd_kafka_event_message_next
- prelude::bindings::rd_kafka_event_name
- prelude::bindings::rd_kafka_event_opaque
- prelude::bindings::rd_kafka_event_stats
- prelude::bindings::rd_kafka_event_topic_partition
- prelude::bindings::rd_kafka_event_topic_partition_list
- prelude::bindings::rd_kafka_event_type
- prelude::bindings::rd_kafka_fatal_error
- prelude::bindings::rd_kafka_flush
- prelude::bindings::rd_kafka_get_debug_contexts
- prelude::bindings::rd_kafka_get_err_descs
- prelude::bindings::rd_kafka_get_watermark_offsets
- prelude::bindings::rd_kafka_group_list_destroy
- prelude::bindings::rd_kafka_group_result_error
- prelude::bindings::rd_kafka_group_result_name
- prelude::bindings::rd_kafka_group_result_partitions
- prelude::bindings::rd_kafka_handle_mock_cluster
- prelude::bindings::rd_kafka_header_add
- prelude::bindings::rd_kafka_header_cnt
- prelude::bindings::rd_kafka_header_get
- prelude::bindings::rd_kafka_header_get_all
- prelude::bindings::rd_kafka_header_get_last
- prelude::bindings::rd_kafka_header_remove
- prelude::bindings::rd_kafka_headers_copy
- prelude::bindings::rd_kafka_headers_destroy
- prelude::bindings::rd_kafka_headers_new
- prelude::bindings::rd_kafka_incremental_assign
- prelude::bindings::rd_kafka_incremental_unassign
- prelude::bindings::rd_kafka_init_transactions
- prelude::bindings::rd_kafka_interceptor_add_on_acknowledgement
- prelude::bindings::rd_kafka_interceptor_add_on_broker_state_change
- prelude::bindings::rd_kafka_interceptor_add_on_commit
- prelude::bindings::rd_kafka_interceptor_add_on_consume
- prelude::bindings::rd_kafka_interceptor_add_on_destroy
- prelude::bindings::rd_kafka_interceptor_add_on_request_sent
- prelude::bindings::rd_kafka_interceptor_add_on_response_received
- prelude::bindings::rd_kafka_interceptor_add_on_send
- prelude::bindings::rd_kafka_interceptor_add_on_thread_exit
- prelude::bindings::rd_kafka_interceptor_add_on_thread_start
- prelude::bindings::rd_kafka_last_error
- prelude::bindings::rd_kafka_list_groups
- prelude::bindings::rd_kafka_log_print
- prelude::bindings::rd_kafka_log_syslog
- prelude::bindings::rd_kafka_mem_calloc
- prelude::bindings::rd_kafka_mem_free
- prelude::bindings::rd_kafka_mem_malloc
- prelude::bindings::rd_kafka_memberid
- prelude::bindings::rd_kafka_message_broker_id
- prelude::bindings::rd_kafka_message_destroy
- prelude::bindings::rd_kafka_message_detach_headers
- prelude::bindings::rd_kafka_message_errstr
- prelude::bindings::rd_kafka_message_headers
- prelude::bindings::rd_kafka_message_latency
- prelude::bindings::rd_kafka_message_leader_epoch
- prelude::bindings::rd_kafka_message_set_headers
- prelude::bindings::rd_kafka_message_status
- prelude::bindings::rd_kafka_message_timestamp
- prelude::bindings::rd_kafka_metadata
- prelude::bindings::rd_kafka_metadata_destroy
- prelude::bindings::rd_kafka_mock_broker_error_stack_cnt
- prelude::bindings::rd_kafka_mock_broker_push_request_error_rtts
- prelude::bindings::rd_kafka_mock_broker_set_down
- prelude::bindings::rd_kafka_mock_broker_set_rack
- prelude::bindings::rd_kafka_mock_broker_set_rtt
- prelude::bindings::rd_kafka_mock_broker_set_up
- prelude::bindings::rd_kafka_mock_clear_request_errors
- prelude::bindings::rd_kafka_mock_clear_requests
- prelude::bindings::rd_kafka_mock_cluster_bootstraps
- prelude::bindings::rd_kafka_mock_cluster_destroy
- prelude::bindings::rd_kafka_mock_cluster_handle
- prelude::bindings::rd_kafka_mock_cluster_new
- prelude::bindings::rd_kafka_mock_coordinator_set
- prelude::bindings::rd_kafka_mock_get_requests
- prelude::bindings::rd_kafka_mock_partition_set_follower
- prelude::bindings::rd_kafka_mock_partition_set_follower_wmarks
- prelude::bindings::rd_kafka_mock_partition_set_leader
- prelude::bindings::rd_kafka_mock_push_request_errors
- prelude::bindings::rd_kafka_mock_push_request_errors_array
- prelude::bindings::rd_kafka_mock_request_api_key
- prelude::bindings::rd_kafka_mock_request_destroy
- prelude::bindings::rd_kafka_mock_request_id
- prelude::bindings::rd_kafka_mock_request_timestamp
- prelude::bindings::rd_kafka_mock_set_apiversion
- prelude::bindings::rd_kafka_mock_start_request_tracking
- prelude::bindings::rd_kafka_mock_stop_request_tracking
- prelude::bindings::rd_kafka_mock_topic_create
- prelude::bindings::rd_kafka_mock_topic_set_error
- prelude::bindings::rd_kafka_msg_partitioner_consistent
- prelude::bindings::rd_kafka_msg_partitioner_consistent_random
- prelude::bindings::rd_kafka_msg_partitioner_fnv1a
- prelude::bindings::rd_kafka_msg_partitioner_fnv1a_random
- prelude::bindings::rd_kafka_msg_partitioner_murmur2
- prelude::bindings::rd_kafka_msg_partitioner_murmur2_random
- prelude::bindings::rd_kafka_msg_partitioner_random
- prelude::bindings::rd_kafka_name
- prelude::bindings::rd_kafka_new
- prelude::bindings::rd_kafka_oauthbearer_set_token
- prelude::bindings::rd_kafka_oauthbearer_set_token_failure
- prelude::bindings::rd_kafka_offset_store
- prelude::bindings::rd_kafka_offset_store_message
- prelude::bindings::rd_kafka_offsets_for_times
- prelude::bindings::rd_kafka_offsets_store
- prelude::bindings::rd_kafka_opaque
- prelude::bindings::rd_kafka_outq_len
- prelude::bindings::rd_kafka_pause_partitions
- prelude::bindings::rd_kafka_poll
- prelude::bindings::rd_kafka_poll_set_consumer
- prelude::bindings::rd_kafka_position
- prelude::bindings::rd_kafka_produce
- prelude::bindings::rd_kafka_produce_batch
- prelude::bindings::rd_kafka_producev
- prelude::bindings::rd_kafka_produceva
- prelude::bindings::rd_kafka_purge
- prelude::bindings::rd_kafka_query_watermark_offsets
- prelude::bindings::rd_kafka_queue_cb_event_enable
- prelude::bindings::rd_kafka_queue_destroy
- prelude::bindings::rd_kafka_queue_forward
- prelude::bindings::rd_kafka_queue_get_background
- prelude::bindings::rd_kafka_queue_get_consumer
- prelude::bindings::rd_kafka_queue_get_main
- prelude::bindings::rd_kafka_queue_get_partition
- prelude::bindings::rd_kafka_queue_get_sasl
- prelude::bindings::rd_kafka_queue_io_event_enable
- prelude::bindings::rd_kafka_queue_length
- prelude::bindings::rd_kafka_queue_new
- prelude::bindings::rd_kafka_queue_poll
- prelude::bindings::rd_kafka_queue_poll_callback
- prelude::bindings::rd_kafka_queue_yield
- prelude::bindings::rd_kafka_rebalance_protocol
- prelude::bindings::rd_kafka_resume_partitions
- prelude::bindings::rd_kafka_sasl_background_callbacks_enable
- prelude::bindings::rd_kafka_sasl_set_credentials
- prelude::bindings::rd_kafka_seek
- prelude::bindings::rd_kafka_seek_partitions
- prelude::bindings::rd_kafka_send_offsets_to_transaction
- prelude::bindings::rd_kafka_set_log_level
- prelude::bindings::rd_kafka_set_log_queue
- prelude::bindings::rd_kafka_set_logger
- prelude::bindings::rd_kafka_subscribe
- prelude::bindings::rd_kafka_subscription
- prelude::bindings::rd_kafka_test_fatal_error
- prelude::bindings::rd_kafka_thread_cnt
- prelude::bindings::rd_kafka_topic_conf_destroy
- prelude::bindings::rd_kafka_topic_conf_dump
- prelude::bindings::rd_kafka_topic_conf_dup
- prelude::bindings::rd_kafka_topic_conf_get
- prelude::bindings::rd_kafka_topic_conf_new
- prelude::bindings::rd_kafka_topic_conf_set
- prelude::bindings::rd_kafka_topic_conf_set_msg_order_cmp
- prelude::bindings::rd_kafka_topic_conf_set_opaque
- prelude::bindings::rd_kafka_topic_conf_set_partitioner_cb
- prelude::bindings::rd_kafka_topic_destroy
- prelude::bindings::rd_kafka_topic_name
- prelude::bindings::rd_kafka_topic_new
- prelude::bindings::rd_kafka_topic_opaque
- prelude::bindings::rd_kafka_topic_partition_available
- prelude::bindings::rd_kafka_topic_partition_destroy
- prelude::bindings::rd_kafka_topic_partition_get_leader_epoch
- prelude::bindings::rd_kafka_topic_partition_list_add
- prelude::bindings::rd_kafka_topic_partition_list_add_range
- prelude::bindings::rd_kafka_topic_partition_list_copy
- prelude::bindings::rd_kafka_topic_partition_list_del
- prelude::bindings::rd_kafka_topic_partition_list_del_by_idx
- prelude::bindings::rd_kafka_topic_partition_list_destroy
- prelude::bindings::rd_kafka_topic_partition_list_find
- prelude::bindings::rd_kafka_topic_partition_list_new
- prelude::bindings::rd_kafka_topic_partition_list_set_offset
- prelude::bindings::rd_kafka_topic_partition_list_sort
- prelude::bindings::rd_kafka_topic_partition_set_leader_epoch
- prelude::bindings::rd_kafka_topic_result_error
- prelude::bindings::rd_kafka_topic_result_error_string
- prelude::bindings::rd_kafka_topic_result_name
- prelude::bindings::rd_kafka_type
- prelude::bindings::rd_kafka_unittest
- prelude::bindings::rd_kafka_unsubscribe
- prelude::bindings::rd_kafka_version
- prelude::bindings::rd_kafka_version_str
- prelude::bindings::rd_kafka_wait_destroyed
- prelude::bindings::rd_kafka_yield
- prelude::helpers::rd_kafka_resp_err_t_to_rdkafka_error
- prelude::util::cstr_to_owned
- prelude::util::current_time_millis
- prelude::util::get_rdkafka_version
- prelude::util::millis_to_epoch
Type Aliases
- errors::Result
- prelude::CWebResult
- prelude::admin::AlterConfigsResult
- prelude::admin::ConfigResourceResult
- prelude::admin::GroupResult
- prelude::admin::PartitionAssignment
- prelude::admin::TopicResult
- prelude::bindings::rd_kafka_AclBindingFilter_t
- prelude::bindings::rd_kafka_AclBinding_t
- prelude::bindings::rd_kafka_AdminOptions_t
- prelude::bindings::rd_kafka_AlterConfigs_result_t
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets_result_t
- prelude::bindings::rd_kafka_AlterConsumerGroupOffsets_t
- prelude::bindings::rd_kafka_AlterUserScramCredentials_result_response_t
- prelude::bindings::rd_kafka_AlterUserScramCredentials_result_t
- prelude::bindings::rd_kafka_ConfigEntry_t
- prelude::bindings::rd_kafka_ConfigResource_t
- prelude::bindings::rd_kafka_ConsumerGroupDescription_t
- prelude::bindings::rd_kafka_ConsumerGroupListing_t
- prelude::bindings::rd_kafka_CreateAcls_result_t
- prelude::bindings::rd_kafka_CreatePartitions_result_t
- prelude::bindings::rd_kafka_CreateTopics_result_t
- prelude::bindings::rd_kafka_DeleteAcls_result_response_t
- prelude::bindings::rd_kafka_DeleteAcls_result_t
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets_result_t
- prelude::bindings::rd_kafka_DeleteConsumerGroupOffsets_t
- prelude::bindings::rd_kafka_DeleteGroup_t
- prelude::bindings::rd_kafka_DeleteGroups_result_t
- prelude::bindings::rd_kafka_DeleteRecords_result_t
- prelude::bindings::rd_kafka_DeleteRecords_t
- prelude::bindings::rd_kafka_DeleteTopic_t
- prelude::bindings::rd_kafka_DeleteTopics_result_t
- prelude::bindings::rd_kafka_DescribeAcls_result_t
- prelude::bindings::rd_kafka_DescribeCluster_result_t
- prelude::bindings::rd_kafka_DescribeConfigs_result_t
- prelude::bindings::rd_kafka_DescribeConsumerGroups_result_t
- prelude::bindings::rd_kafka_DescribeTopics_result_t
- prelude::bindings::rd_kafka_DescribeUserScramCredentials_result_t
- prelude::bindings::rd_kafka_IncrementalAlterConfigs_result_t
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets_result_t
- prelude::bindings::rd_kafka_ListConsumerGroupOffsets_t
- prelude::bindings::rd_kafka_ListConsumerGroupsResult_t
- prelude::bindings::rd_kafka_ListConsumerGroups_result_t
- prelude::bindings::rd_kafka_ListOffsetsResultInfo_t
- prelude::bindings::rd_kafka_ListOffsets_result_t
- prelude::bindings::rd_kafka_MemberAssignment_t
- prelude::bindings::rd_kafka_MemberDescription_t
- prelude::bindings::rd_kafka_NewPartitions_t
- prelude::bindings::rd_kafka_NewTopic_t
- prelude::bindings::rd_kafka_Node_t
- prelude::bindings::rd_kafka_ScramCredentialInfo_t
- prelude::bindings::rd_kafka_TopicCollection_t
- prelude::bindings::rd_kafka_TopicDescription_t
- prelude::bindings::rd_kafka_TopicPartitionInfo_t
- prelude::bindings::rd_kafka_UserScramCredentialAlteration_t
- prelude::bindings::rd_kafka_UserScramCredentialsDescription_t
- prelude::bindings::rd_kafka_Uuid_t
- prelude::bindings::rd_kafka_acl_result_t
- prelude::bindings::rd_kafka_conf_t
- prelude::bindings::rd_kafka_consumer_group_metadata_t
- prelude::bindings::rd_kafka_error_t
- prelude::bindings::rd_kafka_event_t
- prelude::bindings::rd_kafka_event_type_t
- prelude::bindings::rd_kafka_group_result_t
- prelude::bindings::rd_kafka_headers_t
- prelude::bindings::rd_kafka_interceptor_f_on_acknowledgement_t
- prelude::bindings::rd_kafka_interceptor_f_on_broker_state_change_t
- prelude::bindings::rd_kafka_interceptor_f_on_commit_t
- prelude::bindings::rd_kafka_interceptor_f_on_conf_destroy_t
- prelude::bindings::rd_kafka_interceptor_f_on_conf_dup_t
- prelude::bindings::rd_kafka_interceptor_f_on_conf_set_t
- prelude::bindings::rd_kafka_interceptor_f_on_consume_t
- prelude::bindings::rd_kafka_interceptor_f_on_destroy_t
- prelude::bindings::rd_kafka_interceptor_f_on_new_t
- prelude::bindings::rd_kafka_interceptor_f_on_request_sent_t
- prelude::bindings::rd_kafka_interceptor_f_on_response_received_t
- prelude::bindings::rd_kafka_interceptor_f_on_send_t
- prelude::bindings::rd_kafka_interceptor_f_on_thread_exit_t
- prelude::bindings::rd_kafka_interceptor_f_on_thread_start_t
- prelude::bindings::rd_kafka_message_t
- prelude::bindings::rd_kafka_metadata_broker_t
- prelude::bindings::rd_kafka_metadata_partition_t
- prelude::bindings::rd_kafka_metadata_t
- prelude::bindings::rd_kafka_metadata_topic_t
- prelude::bindings::rd_kafka_mock_cluster_t
- prelude::bindings::rd_kafka_mock_request_t
- prelude::bindings::rd_kafka_plugin_f_conf_init_t
- prelude::bindings::rd_kafka_queue_t
- prelude::bindings::rd_kafka_t
- prelude::bindings::rd_kafka_topic_conf_t
- prelude::bindings::rd_kafka_topic_partition_list_t
- prelude::bindings::rd_kafka_topic_partition_t
- prelude::bindings::rd_kafka_topic_result_t
- prelude::bindings::rd_kafka_topic_t
- prelude::bindings::rd_kafka_vu_t
- prelude::error::KafkaResult
- prelude::message::DeliveryResult
- prelude::producer::DeliveryResult
- prelude::producer::base_producer::DeliveryResult
- prelude::producer::future_producer::OwnedDeliveryResult
- prelude::types::RDKafka
- prelude::types::RDKafkaAdminOptions
- prelude::types::RDKafkaConf
- prelude::types::RDKafkaConfigResource
- prelude::types::RDKafkaConsumerGroupMetadata
- prelude::types::RDKafkaDeleteGroup
- prelude::types::RDKafkaDeleteTopic
- prelude::types::RDKafkaEvent
- prelude::types::RDKafkaGroupInfo
- prelude::types::RDKafkaGroupList
- prelude::types::RDKafkaGroupMemberInfo
- prelude::types::RDKafkaGroupResult
- prelude::types::RDKafkaHeaders
- prelude::types::RDKafkaMessage
- prelude::types::RDKafkaMetadata
- prelude::types::RDKafkaMetadataBroker
- prelude::types::RDKafkaMetadataPartition
- prelude::types::RDKafkaMetadataTopic
- prelude::types::RDKafkaMockCluster
- prelude::types::RDKafkaNewPartitions
- prelude::types::RDKafkaNewTopic
- prelude::types::RDKafkaQueue
- prelude::types::RDKafkaState
- prelude::types::RDKafkaTopic
- prelude::types::RDKafkaTopicConf
- prelude::types::RDKafkaTopicPartition
- prelude::types::RDKafkaTopicPartitionList
- prelude::types::RDKafkaTopicResult
- prelude::util::DefaultRuntime
- types::table_agent::Tables
Constants
- prelude::bindings::RD_KAFKA_DEBUG_CONTEXTS
- prelude::bindings::RD_KAFKA_DESTROY_F_NO_CONSUMER_CLOSE
- prelude::bindings::RD_KAFKA_EVENT_ALTERCONFIGS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_ALTERCONSUMERGROUPOFFSETS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_ALTERUSERSCRAMCREDENTIALS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_BACKGROUND
- prelude::bindings::RD_KAFKA_EVENT_CREATEACLS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_CREATEPARTITIONS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_CREATETOPICS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DELETEACLS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DELETECONSUMERGROUPOFFSETS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DELETEGROUPS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DELETERECORDS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DELETETOPICS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DESCRIBEACLS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DESCRIBECLUSTER_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DESCRIBECONFIGS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DESCRIBECONSUMERGROUPS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DESCRIBETOPICS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DESCRIBEUSERSCRAMCREDENTIALS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_DR
- prelude::bindings::RD_KAFKA_EVENT_ERROR
- prelude::bindings::RD_KAFKA_EVENT_FETCH
- prelude::bindings::RD_KAFKA_EVENT_INCREMENTALALTERCONFIGS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_LISTCONSUMERGROUPOFFSETS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_LISTCONSUMERGROUPS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_LISTOFFSETS_RESULT
- prelude::bindings::RD_KAFKA_EVENT_LOG
- prelude::bindings::RD_KAFKA_EVENT_NONE
- prelude::bindings::RD_KAFKA_EVENT_OAUTHBEARER_TOKEN_REFRESH
- prelude::bindings::RD_KAFKA_EVENT_OFFSET_COMMIT
- prelude::bindings::RD_KAFKA_EVENT_REBALANCE
- prelude::bindings::RD_KAFKA_EVENT_STATS
- prelude::bindings::RD_KAFKA_MSG_F_BLOCK
- prelude::bindings::RD_KAFKA_MSG_F_COPY
- prelude::bindings::RD_KAFKA_MSG_F_FREE
- prelude::bindings::RD_KAFKA_MSG_F_PARTITION
- prelude::bindings::RD_KAFKA_OFFSET_BEGINNING
- prelude::bindings::RD_KAFKA_OFFSET_END
- prelude::bindings::RD_KAFKA_OFFSET_INVALID
- prelude::bindings::RD_KAFKA_OFFSET_STORED
- prelude::bindings::RD_KAFKA_OFFSET_TAIL_BASE
- prelude::bindings::RD_KAFKA_PURGE_F_INFLIGHT
- prelude::bindings::RD_KAFKA_PURGE_F_NON_BLOCKING
- prelude::bindings::RD_KAFKA_PURGE_F_QUEUE
- prelude::bindings::RD_KAFKA_VERSION
- prelude::producer::PARTITION_UA