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