Docs.rs
rdkafka-sys-4.8.0+2.3.0
rdkafka-sys 4.8.0+2.3.0
Docs.rs crate page
MIT
Links
Repository
crates.io
Source
Owners
fede1024
flavray
benesch
davidblewett
scanterog
Dependencies
curl-sys ^0.4.55
normal
optional
libc ^0.2.65
normal
libz-sys ^1.0.0
normal
optional
lz4-sys ^1.8.3
normal
optional
num_enum ^0.7.3
normal
openssl-sys ^0.9.48
normal
optional
sasl2-sys ^0.1.6
normal
optional
zstd-sys ^2.0.6
normal
optional
cmake ^0.1.0
build
optional
pkg-config ^0.3.9
build
Versions
15.09%
of the crate is documented
Platform
x86_64-unknown-linux-gnu
Feature flags
Rust
About docs.rs
Privacy policy
Rust website
The Book
Standard Library API Reference
Rust by Example
The Cargo Guide
Clippy Documentation
rdkafka_
sys
4.8.0+2.3.0
Module bindings
Module Items
Structs
Enums
Constants
Functions
Type Aliases
Unions
In crate rdkafka_
sys
rdkafka_sys
Module
bindings
Copy item path
Source
Expand description
FFI bindings.
These bindings are automatically generated with
bindgen
.
Structs
§
rd_
kafka_
AclBinding_
s
rd_
kafka_
Admin
Options_
s
rd_
kafka_
Alter
Consumer
Group
Offsets_
s
rd_
kafka_
Alter
User
Scram
Credentials_
result_
response_
s
rd_
kafka_
Config
Entry_
s
rd_
kafka_
Config
Resource_
s
rd_
kafka_
Consumer
Group
Description_
s
rd_
kafka_
Consumer
Group
Listing_
s
rd_
kafka_
Delete
Acls_
result_
response_
s
rd_
kafka_
Delete
Consumer
Group
Offsets_
s
rd_
kafka_
Delete
Group_
s
rd_
kafka_
Delete
Records_
s
rd_
kafka_
Delete
Topic_
s
rd_
kafka_
List
Consumer
Group
Offsets_
s
rd_
kafka_
List
Consumer
Groups
Result_
s
rd_
kafka_
List
Offsets
Result
Info_
s
rd_
kafka_
Member
Assignment_
s
rd_
kafka_
Member
Description_
s
rd_
kafka_
NewPartitions_
s
rd_
kafka_
NewTopic_
s
rd_
kafka_
Node_
s
rd_
kafka_
Scram
Credential
Info_
s
rd_
kafka_
Topic
Collection_
s
rd_
kafka_
Topic
Description_
s
rd_
kafka_
Topic
Partition
Info_
s
rd_
kafka_
User
Scram
Credential
Alteration_
s
rd_
kafka_
User
Scram
Credentials
Description_
s
rd_
kafka_
Uuid_
s
rd_
kafka_
acl_
result_
s
rd_
kafka_
conf_
s
rd_
kafka_
consumer_
group_
metadata_
s
rd_
kafka_
err_
desc
rd_
kafka_
error_
s
rd_
kafka_
group_
info
rd_
kafka_
group_
list
rd_
kafka_
group_
member_
info
rd_
kafka_
group_
result_
s
rd_
kafka_
headers_
s
rd_
kafka_
message_
s
rd_
kafka_
metadata
rd_
kafka_
metadata_
broker
rd_
kafka_
metadata_
partition
rd_
kafka_
metadata_
topic
rd_
kafka_
mock_
cluster_
s
rd_
kafka_
mock_
request_
s
rd_
kafka_
op_
s
rd_
kafka_
queue_
s
rd_
kafka_
s
rd_
kafka_
topic_
conf_
s
rd_
kafka_
topic_
partition_
list_
s
rd_
kafka_
topic_
partition_
s
rd_
kafka_
topic_
result_
s
rd_
kafka_
topic_
s
rd_
kafka_
vu_
s
rd_
kafka_
vu_
s__
bindgen_
ty_
1__
bindgen_
ty_
1
rd_
kafka_
vu_
s__
bindgen_
ty_
1__
bindgen_
ty_
2
Enums
§
rd_
kafka_
AclOperation_
t
rd_
kafka_
AclPermission
Type_
t
rd_
kafka_
Alter
Config
OpType_
t
rd_
kafka_
Config
Source_
t
rd_
kafka_
Isolation
Level_
t
rd_
kafka_
Offset
Spec_
t
rd_
kafka_
Resource
Pattern
Type_
t
rd_
kafka_
Resource
Type_
t
rd_
kafka_
Scram
Mechanism_
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_
AclBinding
Filter_
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_
AclPermission
Type_
name
⚠
rd_
kafka_
Admin
Options_
destroy
⚠
rd_
kafka_
Admin
Options_
new
⚠
rd_
kafka_
Admin
Options_
set_
broker
⚠
rd_
kafka_
Admin
Options_
set_
include_
authorized_
operations
⚠
rd_
kafka_
Admin
Options_
set_
isolation_
level
⚠
rd_
kafka_
Admin
Options_
set_
match_
consumer_
group_
states
⚠
rd_
kafka_
Admin
Options_
set_
opaque
⚠
rd_
kafka_
Admin
Options_
set_
operation_
timeout
⚠
rd_
kafka_
Admin
Options_
set_
request_
timeout
⚠
rd_
kafka_
Admin
Options_
set_
require_
stable_
offsets
⚠
rd_
kafka_
Admin
Options_
set_
validate_
only
⚠
rd_
kafka_
Alter
Configs
⚠
rd_
kafka_
Alter
Configs_
result_
resources
⚠
rd_
kafka_
Alter
Consumer
Group
Offsets
⚠
rd_
kafka_
Alter
Consumer
Group
Offsets_
destroy
⚠
rd_
kafka_
Alter
Consumer
Group
Offsets_
destroy_
array
⚠
rd_
kafka_
Alter
Consumer
Group
Offsets_
new
⚠
rd_
kafka_
Alter
Consumer
Group
Offsets_
result_
groups
⚠
rd_
kafka_
Alter
User
Scram
Credentials
⚠
rd_
kafka_
Alter
User
Scram
Credentials_
result_
response_
error
⚠
rd_
kafka_
Alter
User
Scram
Credentials_
result_
response_
user
⚠
rd_
kafka_
Alter
User
Scram
Credentials_
result_
responses
⚠
rd_
kafka_
Config
Entry_
is_
default
⚠
rd_
kafka_
Config
Entry_
is_
read_
only
⚠
rd_
kafka_
Config
Entry_
is_
sensitive
⚠
rd_
kafka_
Config
Entry_
is_
synonym
⚠
rd_
kafka_
Config
Entry_
name
⚠
rd_
kafka_
Config
Entry_
source
⚠
rd_
kafka_
Config
Entry_
synonyms
⚠
rd_
kafka_
Config
Entry_
value
⚠
rd_
kafka_
Config
Resource_
add_
incremental_
config
⚠
rd_
kafka_
Config
Resource_
configs
⚠
rd_
kafka_
Config
Resource_
destroy
⚠
rd_
kafka_
Config
Resource_
destroy_
array
⚠
rd_
kafka_
Config
Resource_
error
⚠
rd_
kafka_
Config
Resource_
error_
string
⚠
rd_
kafka_
Config
Resource_
name
⚠
rd_
kafka_
Config
Resource_
new
⚠
rd_
kafka_
Config
Resource_
set_
config
⚠
rd_
kafka_
Config
Resource_
type
⚠
rd_
kafka_
Config
Source_
name
⚠
rd_
kafka_
Consumer
Group
Description_
authorized_
operations
⚠
rd_
kafka_
Consumer
Group
Description_
coordinator
⚠
rd_
kafka_
Consumer
Group
Description_
error
⚠
rd_
kafka_
Consumer
Group
Description_
group_
id
⚠
rd_
kafka_
Consumer
Group
Description_
is_
simple_
consumer_
group
⚠
rd_
kafka_
Consumer
Group
Description_
member
⚠
rd_
kafka_
Consumer
Group
Description_
member_
count
⚠
rd_
kafka_
Consumer
Group
Description_
partition_
assignor
⚠
rd_
kafka_
Consumer
Group
Description_
state
⚠
rd_
kafka_
Consumer
Group
Listing_
group_
id
⚠
rd_
kafka_
Consumer
Group
Listing_
is_
simple_
consumer_
group
⚠
rd_
kafka_
Consumer
Group
Listing_
state
⚠
rd_
kafka_
Create
Acls
⚠
rd_
kafka_
Create
Acls_
result_
acls
⚠
rd_
kafka_
Create
Partitions
⚠
rd_
kafka_
Create
Partitions_
result_
topics
⚠
rd_
kafka_
Create
Topics
⚠
rd_
kafka_
Create
Topics_
result_
topics
⚠
rd_
kafka_
Delete
Acls
⚠
rd_
kafka_
Delete
Acls_
result_
response_
error
⚠
rd_
kafka_
Delete
Acls_
result_
response_
matching_
acls
⚠
rd_
kafka_
Delete
Acls_
result_
responses
⚠
rd_
kafka_
Delete
Consumer
Group
Offsets
⚠
rd_
kafka_
Delete
Consumer
Group
Offsets_
destroy
⚠
rd_
kafka_
Delete
Consumer
Group
Offsets_
destroy_
array
⚠
rd_
kafka_
Delete
Consumer
Group
Offsets_
new
⚠
rd_
kafka_
Delete
Consumer
Group
Offsets_
result_
groups
⚠
rd_
kafka_
Delete
Group_
destroy
⚠
rd_
kafka_
Delete
Group_
destroy_
array
⚠
rd_
kafka_
Delete
Group_
new
⚠
rd_
kafka_
Delete
Groups
⚠
rd_
kafka_
Delete
Groups_
result_
groups
⚠
rd_
kafka_
Delete
Records
⚠
rd_
kafka_
Delete
Records_
destroy
⚠
rd_
kafka_
Delete
Records_
destroy_
array
⚠
rd_
kafka_
Delete
Records_
new
⚠
rd_
kafka_
Delete
Records_
result_
offsets
⚠
rd_
kafka_
Delete
Topic_
destroy
⚠
rd_
kafka_
Delete
Topic_
destroy_
array
⚠
rd_
kafka_
Delete
Topic_
new
⚠
rd_
kafka_
Delete
Topics
⚠
rd_
kafka_
Delete
Topics_
result_
topics
⚠
rd_
kafka_
Describe
Acls
⚠
rd_
kafka_
Describe
Acls_
result_
acls
⚠
rd_
kafka_
Describe
Cluster
⚠
rd_
kafka_
Describe
Cluster_
result_
authorized_
operations
⚠
rd_
kafka_
Describe
Cluster_
result_
cluster_
id
⚠
rd_
kafka_
Describe
Cluster_
result_
controller
⚠
rd_
kafka_
Describe
Cluster_
result_
nodes
⚠
rd_
kafka_
Describe
Configs
⚠
rd_
kafka_
Describe
Configs_
result_
resources
⚠
rd_
kafka_
Describe
Consumer
Groups
⚠
rd_
kafka_
Describe
Consumer
Groups_
result_
groups
⚠
rd_
kafka_
Describe
Topics
⚠
rd_
kafka_
Describe
Topics_
result_
topics
⚠
rd_
kafka_
Describe
User
Scram
Credentials
⚠
rd_
kafka_
Describe
User
Scram
Credentials_
result_
descriptions
⚠
rd_
kafka_
Incremental
Alter
Configs
⚠
rd_
kafka_
Incremental
Alter
Configs_
result_
resources
⚠
rd_
kafka_
List
Consumer
Group
Offsets
⚠
rd_
kafka_
List
Consumer
Group
Offsets_
destroy
⚠
rd_
kafka_
List
Consumer
Group
Offsets_
destroy_
array
⚠
rd_
kafka_
List
Consumer
Group
Offsets_
new
⚠
rd_
kafka_
List
Consumer
Group
Offsets_
result_
groups
⚠
rd_
kafka_
List
Consumer
Groups
⚠
rd_
kafka_
List
Consumer
Groups_
result_
errors
⚠
rd_
kafka_
List
Consumer
Groups_
result_
valid
⚠
rd_
kafka_
List
Offsets
⚠
rd_
kafka_
List
Offsets
Result
Info_
timestamp
⚠
rd_
kafka_
List
Offsets
Result
Info_
topic_
partition
⚠
rd_
kafka_
List
Offsets_
result_
infos
⚠
rd_
kafka_
Member
Assignment_
partitions
⚠
rd_
kafka_
Member
Description_
assignment
⚠
rd_
kafka_
Member
Description_
client_
id
⚠
rd_
kafka_
Member
Description_
consumer_
id
⚠
rd_
kafka_
Member
Description_
group_
instance_
id
⚠
rd_
kafka_
Member
Description_
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_
Resource
Pattern
Type_
name
⚠
rd_
kafka_
Resource
Type_
name
⚠
rd_
kafka_
Scram
Credential
Info_
iterations
⚠
rd_
kafka_
Scram
Credential
Info_
mechanism
⚠
rd_
kafka_
Topic
Collection_
destroy
⚠
rd_
kafka_
Topic
Collection_
of_
topic_
names
⚠
rd_
kafka_
Topic
Description_
authorized_
operations
⚠
rd_
kafka_
Topic
Description_
error
⚠
rd_
kafka_
Topic
Description_
is_
internal
⚠
rd_
kafka_
Topic
Description_
name
⚠
rd_
kafka_
Topic
Description_
partitions
⚠
rd_
kafka_
Topic
Description_
topic_
id
⚠
rd_
kafka_
Topic
Partition
Info_
isr
⚠
rd_
kafka_
Topic
Partition
Info_
leader
⚠
rd_
kafka_
Topic
Partition
Info_
partition
⚠
rd_
kafka_
Topic
Partition
Info_
replicas
⚠
rd_
kafka_
User
Scram
Credential
Alteration_
destroy
⚠
rd_
kafka_
User
Scram
Credential
Alteration_
destroy_
array
⚠
rd_
kafka_
User
Scram
Credential
Deletion_
new
⚠
rd_
kafka_
User
Scram
Credential
Upsertion_
new
⚠
rd_
kafka_
User
Scram
Credentials
Description_
error
⚠
rd_
kafka_
User
Scram
Credentials
Description_
scramcredentialinfo
⚠
rd_
kafka_
User
Scram
Credentials
Description_
scramcredentialinfo_
count
⚠
rd_
kafka_
User
Scram
Credentials
Description_
user
⚠
rd_
kafka_
Uuid_
base64str
⚠
rd_
kafka_
Uuid_
copy
⚠
rd_
kafka_
Uuid_
destroy
⚠
rd_
kafka_
Uuid_
least_
significant_
bits
⚠
rd_
kafka_
Uuid_
most_
significant_
bits
⚠
rd_
kafka_
Uuid_
new
⚠
rd_
kafka_
abort_
transaction
⚠
rd_
kafka_
acl_
result_
error
⚠
rd_
kafka_
assign
⚠
rd_
kafka_
assignment
⚠
rd_
kafka_
assignment_
lost
⚠
rd_
kafka_
begin_
transaction
⚠
rd_
kafka_
brokers_
add
⚠
rd_
kafka_
clusterid
⚠
rd_
kafka_
commit
⚠
rd_
kafka_
commit_
message
⚠
rd_
kafka_
commit_
queue
⚠
rd_
kafka_
commit_
transaction
⚠
rd_
kafka_
committed
⚠
rd_
kafka_
conf
⚠
rd_
kafka_
conf_
destroy
⚠
rd_
kafka_
conf_
dump
⚠
rd_
kafka_
conf_
dump_
free
⚠
rd_
kafka_
conf_
dup
⚠
rd_
kafka_
conf_
dup_
filter
⚠
rd_
kafka_
conf_
enable_
sasl_
queue
⚠
rd_
kafka_
conf_
get
⚠
rd_
kafka_
conf_
get_
default_
topic_
conf
⚠
rd_
kafka_
conf_
interceptor_
add_
on_
conf_
destroy
⚠
rd_
kafka_
conf_
interceptor_
add_
on_
conf_
dup
⚠
rd_
kafka_
conf_
interceptor_
add_
on_
conf_
set
⚠
rd_
kafka_
conf_
interceptor_
add_
on_
new
⚠
rd_
kafka_
conf_
new
⚠
rd_
kafka_
conf_
properties_
show
⚠
rd_
kafka_
conf_
set
⚠
rd_
kafka_
conf_
set_
background_
event_
cb
⚠
rd_
kafka_
conf_
set_
closesocket_
cb
⚠
rd_
kafka_
conf_
set_
connect_
cb
⚠
rd_
kafka_
conf_
set_
consume_
cb
⚠
rd_
kafka_
conf_
set_
default_
topic_
conf
⚠
rd_
kafka_
conf_
set_
dr_
cb
⚠
rd_
kafka_
conf_
set_
dr_
msg_
cb
⚠
rd_
kafka_
conf_
set_
engine_
callback_
data
⚠
rd_
kafka_
conf_
set_
error_
cb
⚠
rd_
kafka_
conf_
set_
events
⚠
rd_
kafka_
conf_
set_
log_
cb
⚠
rd_
kafka_
conf_
set_
oauthbearer_
token_
refresh_
cb
⚠
rd_
kafka_
conf_
set_
offset_
commit_
cb
⚠
rd_
kafka_
conf_
set_
opaque
⚠
rd_
kafka_
conf_
set_
rebalance_
cb
⚠
rd_
kafka_
conf_
set_
socket_
cb
⚠
rd_
kafka_
conf_
set_
ssl_
cert
⚠
rd_
kafka_
conf_
set_
ssl_
cert_
verify_
cb
⚠
rd_
kafka_
conf_
set_
stats_
cb
⚠
rd_
kafka_
conf_
set_
throttle_
cb
⚠
rd_
kafka_
consume
⚠
rd_
kafka_
consume_
batch
⚠
rd_
kafka_
consume_
batch_
queue
⚠
rd_
kafka_
consume_
callback
⚠
rd_
kafka_
consume_
callback_
queue
⚠
rd_
kafka_
consume_
queue
⚠
rd_
kafka_
consume_
start
⚠
rd_
kafka_
consume_
start_
queue
⚠
rd_
kafka_
consume_
stop
⚠
rd_
kafka_
consumer_
close
⚠
rd_
kafka_
consumer_
close_
queue
⚠
rd_
kafka_
consumer_
closed
⚠
rd_
kafka_
consumer_
group_
metadata
⚠
rd_
kafka_
consumer_
group_
metadata_
destroy
⚠
rd_
kafka_
consumer_
group_
metadata_
new
⚠
rd_
kafka_
consumer_
group_
metadata_
new_
with_
genid
⚠
rd_
kafka_
consumer_
group_
metadata_
read
⚠
rd_
kafka_
consumer_
group_
metadata_
write
⚠
rd_
kafka_
consumer_
group_
state_
code
⚠
rd_
kafka_
consumer_
group_
state_
name
⚠
rd_
kafka_
consumer_
poll
⚠
rd_
kafka_
controllerid
⚠
rd_
kafka_
default_
topic_
conf_
dup
⚠
rd_
kafka_
destroy
⚠
rd_
kafka_
destroy_
flags
⚠
rd_
kafka_
dump
⚠
rd_
kafka_
err2name
⚠
rd_
kafka_
err2str
⚠
rd_
kafka_
errno
⚠
rd_
kafka_
errno2err
⚠
rd_
kafka_
error_
code
⚠
rd_
kafka_
error_
destroy
⚠
rd_
kafka_
error_
is_
fatal
⚠
rd_
kafka_
error_
is_
retriable
⚠
rd_
kafka_
error_
name
⚠
rd_
kafka_
error_
new
⚠
rd_
kafka_
error_
string
⚠
rd_
kafka_
error_
txn_
requires_
abort
⚠
rd_
kafka_
event_
Alter
Configs_
result
⚠
rd_
kafka_
event_
Alter
Consumer
Group
Offsets_
result
⚠
rd_
kafka_
event_
Alter
User
Scram
Credentials_
result
⚠
rd_
kafka_
event_
Create
Acls_
result
⚠
rd_
kafka_
event_
Create
Partitions_
result
⚠
rd_
kafka_
event_
Create
Topics_
result
⚠
rd_
kafka_
event_
Delete
Acls_
result
⚠
rd_
kafka_
event_
Delete
Consumer
Group
Offsets_
result
⚠
rd_
kafka_
event_
Delete
Groups_
result
⚠
rd_
kafka_
event_
Delete
Records_
result
⚠
rd_
kafka_
event_
Delete
Topics_
result
⚠
rd_
kafka_
event_
Describe
Acls_
result
⚠
rd_
kafka_
event_
Describe
Cluster_
result
⚠
rd_
kafka_
event_
Describe
Configs_
result
⚠
rd_
kafka_
event_
Describe
Consumer
Groups_
result
⚠
rd_
kafka_
event_
Describe
Topics_
result
⚠
rd_
kafka_
event_
Describe
User
Scram
Credentials_
result
⚠
rd_
kafka_
event_
Incremental
Alter
Configs_
result
⚠
rd_
kafka_
event_
List
Consumer
Group
Offsets_
result
⚠
rd_
kafka_
event_
List
Consumer
Groups_
result
⚠
rd_
kafka_
event_
List
Offsets_
result
⚠
rd_
kafka_
event_
config_
string
⚠
rd_
kafka_
event_
debug_
contexts
⚠
rd_
kafka_
event_
destroy
⚠
rd_
kafka_
event_
error
⚠
rd_
kafka_
event_
error_
is_
fatal
⚠
rd_
kafka_
event_
error_
string
⚠
rd_
kafka_
event_
log
⚠
rd_
kafka_
event_
message_
array
⚠
rd_
kafka_
event_
message_
count
⚠
rd_
kafka_
event_
message_
next
⚠
rd_
kafka_
event_
name
⚠
rd_
kafka_
event_
opaque
⚠
rd_
kafka_
event_
stats
⚠
rd_
kafka_
event_
topic_
partition
⚠
rd_
kafka_
event_
topic_
partition_
list
⚠
rd_
kafka_
event_
type
⚠
rd_
kafka_
fatal_
error
⚠
rd_
kafka_
flush
⚠
rd_
kafka_
get_
debug_
contexts
⚠
rd_
kafka_
get_
err_
descs
⚠
rd_
kafka_
get_
watermark_
offsets
⚠
rd_
kafka_
group_
list_
destroy
⚠
rd_
kafka_
group_
result_
error
⚠
rd_
kafka_
group_
result_
name
⚠
rd_
kafka_
group_
result_
partitions
⚠
rd_
kafka_
handle_
mock_
cluster
⚠
rd_
kafka_
header_
add
⚠
rd_
kafka_
header_
cnt
⚠
rd_
kafka_
header_
get
⚠
rd_
kafka_
header_
get_
all
⚠
rd_
kafka_
header_
get_
last
⚠
rd_
kafka_
header_
remove
⚠
rd_
kafka_
headers_
copy
⚠
rd_
kafka_
headers_
destroy
⚠
rd_
kafka_
headers_
new
⚠
rd_
kafka_
incremental_
assign
⚠
rd_
kafka_
incremental_
unassign
⚠
rd_
kafka_
init_
transactions
⚠
rd_
kafka_
interceptor_
add_
on_
acknowledgement
⚠
rd_
kafka_
interceptor_
add_
on_
broker_
state_
change
⚠
rd_
kafka_
interceptor_
add_
on_
commit
⚠
rd_
kafka_
interceptor_
add_
on_
consume
⚠
rd_
kafka_
interceptor_
add_
on_
destroy
⚠
rd_
kafka_
interceptor_
add_
on_
request_
sent
⚠
rd_
kafka_
interceptor_
add_
on_
response_
received
⚠
rd_
kafka_
interceptor_
add_
on_
send
⚠
rd_
kafka_
interceptor_
add_
on_
thread_
exit
⚠
rd_
kafka_
interceptor_
add_
on_
thread_
start
⚠
rd_
kafka_
last_
error
⚠
rd_
kafka_
list_
groups
⚠
rd_
kafka_
log_
print
⚠
rd_
kafka_
log_
syslog
⚠
rd_
kafka_
mem_
calloc
⚠
rd_
kafka_
mem_
free
⚠
rd_
kafka_
mem_
malloc
⚠
rd_
kafka_
memberid
⚠
rd_
kafka_
message_
broker_
id
⚠
rd_
kafka_
message_
destroy
⚠
rd_
kafka_
message_
detach_
headers
⚠
rd_
kafka_
message_
errstr
⚠
rd_
kafka_
message_
headers
⚠
rd_
kafka_
message_
latency
⚠
rd_
kafka_
message_
leader_
epoch
⚠
rd_
kafka_
message_
set_
headers
⚠
rd_
kafka_
message_
status
⚠
rd_
kafka_
message_
timestamp
⚠
rd_
kafka_
metadata
⚠
rd_
kafka_
metadata_
destroy
⚠
rd_
kafka_
mock_
broker_
error_
stack_
cnt
⚠
rd_
kafka_
mock_
broker_
push_
request_
error_
rtts
⚠
rd_
kafka_
mock_
broker_
set_
down
⚠
rd_
kafka_
mock_
broker_
set_
rack
⚠
rd_
kafka_
mock_
broker_
set_
rtt
⚠
rd_
kafka_
mock_
broker_
set_
up
⚠
rd_
kafka_
mock_
clear_
request_
errors
⚠
rd_
kafka_
mock_
clear_
requests
⚠
rd_
kafka_
mock_
cluster_
bootstraps
⚠
rd_
kafka_
mock_
cluster_
destroy
⚠
rd_
kafka_
mock_
cluster_
handle
⚠
rd_
kafka_
mock_
cluster_
new
⚠
rd_
kafka_
mock_
coordinator_
set
⚠
rd_
kafka_
mock_
get_
requests
⚠
rd_
kafka_
mock_
partition_
set_
follower
⚠
rd_
kafka_
mock_
partition_
set_
follower_
wmarks
⚠
rd_
kafka_
mock_
partition_
set_
leader
⚠
rd_
kafka_
mock_
push_
request_
errors
⚠
rd_
kafka_
mock_
push_
request_
errors_
array
⚠
rd_
kafka_
mock_
request_
api_
key
⚠
rd_
kafka_
mock_
request_
destroy
⚠
rd_
kafka_
mock_
request_
id
⚠
rd_
kafka_
mock_
request_
timestamp
⚠
rd_
kafka_
mock_
set_
apiversion
⚠
rd_
kafka_
mock_
start_
request_
tracking
⚠
rd_
kafka_
mock_
stop_
request_
tracking
⚠
rd_
kafka_
mock_
topic_
create
⚠
rd_
kafka_
mock_
topic_
set_
error
⚠
rd_
kafka_
msg_
partitioner_
consistent
⚠
rd_
kafka_
msg_
partitioner_
consistent_
random
⚠
rd_
kafka_
msg_
partitioner_
fnv1a
⚠
rd_
kafka_
msg_
partitioner_
fnv1a_
random
⚠
rd_
kafka_
msg_
partitioner_
murmur2
⚠
rd_
kafka_
msg_
partitioner_
murmur2_
random
⚠
rd_
kafka_
msg_
partitioner_
random
⚠
rd_
kafka_
name
⚠
rd_
kafka_
new
⚠
rd_
kafka_
oauthbearer_
set_
token
⚠
rd_
kafka_
oauthbearer_
set_
token_
failure
⚠
rd_
kafka_
offset_
store
⚠
rd_
kafka_
offset_
store_
message
⚠
rd_
kafka_
offsets_
for_
times
⚠
rd_
kafka_
offsets_
store
⚠
rd_
kafka_
opaque
⚠
rd_
kafka_
outq_
len
⚠
rd_
kafka_
pause_
partitions
⚠
rd_
kafka_
poll
⚠
rd_
kafka_
poll_
set_
consumer
⚠
rd_
kafka_
position
⚠
rd_
kafka_
produce
⚠
rd_
kafka_
produce_
batch
⚠
rd_
kafka_
producev
⚠
rd_
kafka_
produceva
⚠
rd_
kafka_
purge
⚠
rd_
kafka_
query_
watermark_
offsets
⚠
rd_
kafka_
queue_
cb_
event_
enable
⚠
rd_
kafka_
queue_
destroy
⚠
rd_
kafka_
queue_
forward
⚠
rd_
kafka_
queue_
get_
background
⚠
rd_
kafka_
queue_
get_
consumer
⚠
rd_
kafka_
queue_
get_
main
⚠
rd_
kafka_
queue_
get_
partition
⚠
rd_
kafka_
queue_
get_
sasl
⚠
rd_
kafka_
queue_
io_
event_
enable
⚠
rd_
kafka_
queue_
length
⚠
rd_
kafka_
queue_
new
⚠
rd_
kafka_
queue_
poll
⚠
rd_
kafka_
queue_
poll_
callback
⚠
rd_
kafka_
queue_
yield
⚠
rd_
kafka_
rebalance_
protocol
⚠
rd_
kafka_
resume_
partitions
⚠
rd_
kafka_
sasl_
background_
callbacks_
enable
⚠
rd_
kafka_
sasl_
set_
credentials
⚠
rd_
kafka_
seek
⚠
rd_
kafka_
seek_
partitions
⚠
rd_
kafka_
send_
offsets_
to_
transaction
⚠
rd_
kafka_
set_
log_
level
⚠
rd_
kafka_
set_
log_
queue
⚠
rd_
kafka_
set_
logger
⚠
rd_
kafka_
subscribe
⚠
rd_
kafka_
subscription
⚠
rd_
kafka_
test_
fatal_
error
⚠
rd_
kafka_
thread_
cnt
⚠
rd_
kafka_
topic_
conf_
destroy
⚠
rd_
kafka_
topic_
conf_
dump
⚠
rd_
kafka_
topic_
conf_
dup
⚠
rd_
kafka_
topic_
conf_
get
⚠
rd_
kafka_
topic_
conf_
new
⚠
rd_
kafka_
topic_
conf_
set
⚠
rd_
kafka_
topic_
conf_
set_
msg_
order_
cmp
⚠
rd_
kafka_
topic_
conf_
set_
opaque
⚠
rd_
kafka_
topic_
conf_
set_
partitioner_
cb
⚠
rd_
kafka_
topic_
destroy
⚠
rd_
kafka_
topic_
name
⚠
rd_
kafka_
topic_
new
⚠
rd_
kafka_
topic_
opaque
⚠
rd_
kafka_
topic_
partition_
available
⚠
rd_
kafka_
topic_
partition_
destroy
⚠
rd_
kafka_
topic_
partition_
get_
leader_
epoch
⚠
rd_
kafka_
topic_
partition_
list_
add
⚠
rd_
kafka_
topic_
partition_
list_
add_
range
⚠
rd_
kafka_
topic_
partition_
list_
copy
⚠
rd_
kafka_
topic_
partition_
list_
del
⚠
rd_
kafka_
topic_
partition_
list_
del_
by_
idx
⚠
rd_
kafka_
topic_
partition_
list_
destroy
⚠
rd_
kafka_
topic_
partition_
list_
find
⚠
rd_
kafka_
topic_
partition_
list_
new
⚠
rd_
kafka_
topic_
partition_
list_
set_
offset
⚠
rd_
kafka_
topic_
partition_
list_
sort
⚠
rd_
kafka_
topic_
partition_
set_
leader_
epoch
⚠
rd_
kafka_
topic_
result_
error
⚠
rd_
kafka_
topic_
result_
error_
string
⚠
rd_
kafka_
topic_
result_
name
⚠
rd_
kafka_
type
⚠
rd_
kafka_
unittest
⚠
rd_
kafka_
unsubscribe
⚠
rd_
kafka_
version
⚠
rd_
kafka_
version_
str
⚠
rd_
kafka_
wait_
destroyed
⚠
rd_
kafka_
yield
⚠
Type Aliases
§
rd_
kafka_
AclBinding
Filter_
t
rd_
kafka_
AclBinding_
t
rd_
kafka_
Admin
Options_
t
rd_
kafka_
Alter
Configs_
result_
t
rd_
kafka_
Alter
Consumer
Group
Offsets_
result_
t
rd_
kafka_
Alter
Consumer
Group
Offsets_
t
rd_
kafka_
Alter
User
Scram
Credentials_
result_
response_
t
rd_
kafka_
Alter
User
Scram
Credentials_
result_
t
rd_
kafka_
Config
Entry_
t
rd_
kafka_
Config
Resource_
t
rd_
kafka_
Consumer
Group
Description_
t
rd_
kafka_
Consumer
Group
Listing_
t
rd_
kafka_
Create
Acls_
result_
t
rd_
kafka_
Create
Partitions_
result_
t
rd_
kafka_
Create
Topics_
result_
t
rd_
kafka_
Delete
Acls_
result_
response_
t
rd_
kafka_
Delete
Acls_
result_
t
rd_
kafka_
Delete
Consumer
Group
Offsets_
result_
t
rd_
kafka_
Delete
Consumer
Group
Offsets_
t
rd_
kafka_
Delete
Group_
t
rd_
kafka_
Delete
Groups_
result_
t
rd_
kafka_
Delete
Records_
result_
t
rd_
kafka_
Delete
Records_
t
rd_
kafka_
Delete
Topic_
t
rd_
kafka_
Delete
Topics_
result_
t
rd_
kafka_
Describe
Acls_
result_
t
rd_
kafka_
Describe
Cluster_
result_
t
rd_
kafka_
Describe
Configs_
result_
t
rd_
kafka_
Describe
Consumer
Groups_
result_
t
rd_
kafka_
Describe
Topics_
result_
t
rd_
kafka_
Describe
User
Scram
Credentials_
result_
t
rd_
kafka_
Incremental
Alter
Configs_
result_
t
rd_
kafka_
List
Consumer
Group
Offsets_
result_
t
rd_
kafka_
List
Consumer
Group
Offsets_
t
rd_
kafka_
List
Consumer
Groups
Result_
t
rd_
kafka_
List
Consumer
Groups_
result_
t
rd_
kafka_
List
Offsets
Result
Info_
t
rd_
kafka_
List
Offsets_
result_
t
rd_
kafka_
Member
Assignment_
t
rd_
kafka_
Member
Description_
t
rd_
kafka_
NewPartitions_
t
rd_
kafka_
NewTopic_
t
rd_
kafka_
Node_
t
rd_
kafka_
Scram
Credential
Info_
t
rd_
kafka_
Topic
Collection_
t
rd_
kafka_
Topic
Description_
t
rd_
kafka_
Topic
Partition
Info_
t
rd_
kafka_
User
Scram
Credential
Alteration_
t
rd_
kafka_
User
Scram
Credentials
Description_
t
rd_
kafka_
Uuid_
t
rd_
kafka_
acl_
result_
t
rd_
kafka_
conf_
t
rd_
kafka_
consumer_
group_
metadata_
t
rd_
kafka_
error_
t
rd_
kafka_
event_
t
rd_
kafka_
event_
type_
t
rd_
kafka_
group_
result_
t
rd_
kafka_
headers_
t
rd_
kafka_
interceptor_
f_
on_
acknowledgement_
t
rd_
kafka_
interceptor_
f_
on_
broker_
state_
change_
t
rd_
kafka_
interceptor_
f_
on_
commit_
t
rd_
kafka_
interceptor_
f_
on_
conf_
destroy_
t
rd_
kafka_
interceptor_
f_
on_
conf_
dup_
t
rd_
kafka_
interceptor_
f_
on_
conf_
set_
t
rd_
kafka_
interceptor_
f_
on_
consume_
t
rd_
kafka_
interceptor_
f_
on_
destroy_
t
rd_
kafka_
interceptor_
f_
on_
new_
t
rd_
kafka_
interceptor_
f_
on_
request_
sent_
t
rd_
kafka_
interceptor_
f_
on_
response_
received_
t
rd_
kafka_
interceptor_
f_
on_
send_
t
rd_
kafka_
interceptor_
f_
on_
thread_
exit_
t
rd_
kafka_
interceptor_
f_
on_
thread_
start_
t
rd_
kafka_
message_
t
rd_
kafka_
metadata_
broker_
t
rd_
kafka_
metadata_
partition_
t
rd_
kafka_
metadata_
t
rd_
kafka_
metadata_
topic_
t
rd_
kafka_
mock_
cluster_
t
rd_
kafka_
mock_
request_
t
rd_
kafka_
plugin_
f_
conf_
init_
t
rd_
kafka_
queue_
t
rd_
kafka_
t
rd_
kafka_
topic_
conf_
t
rd_
kafka_
topic_
partition_
list_
t
rd_
kafka_
topic_
partition_
t
rd_
kafka_
topic_
result_
t
rd_
kafka_
topic_
t
rd_
kafka_
vu_
t
Unions
§
rd_
kafka_
vu_
s__
bindgen_
ty_
1