rdkafka_
sys
4.3.0+2.5.0
In rdkafka_
sys::
bindings
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_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_resolve_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_member_id
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_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_produce_errstr
rd_kafka_message_set_headers
rd_kafka_message_status
rd_kafka_message_timestamp
rd_kafka_metadata
rd_kafka_metadata_destroy
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_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
rdkafka_sys
::
bindings
Function
rd_kafka_poll_set_consumer
Copy item path
Settings
Help
Summary
Source
pub unsafe extern "C" fn rd_kafka_poll_set_consumer( rk:
*mut
rd_kafka_t
, ) ->
rd_kafka_resp_err_t