- a -

• abort_transaction() : RdKafka::Producer
• add() : RdKafka::Headers
• assign() : RdKafka::KafkaConsumer
• assignment() : RdKafka::KafkaConsumer
• assignment_lost() : RdKafka::KafkaConsumer

- b -

• begin_transaction() : RdKafka::Producer
• broker_id() : RdKafka::Event , RdKafka::Message
• broker_name() : RdKafka::Event
• brokers() : RdKafka::Metadata

- c -

• c_ptr() : RdKafka::Handle , RdKafka::Message , RdKafka::Topic
• c_ptr_global() : RdKafka::Conf
• c_ptr_topic() : RdKafka::Conf
• close() : RdKafka::KafkaConsumer
• clusterid() : RdKafka::Handle
• code() : RdKafka::Error
• commit_transaction() : RdKafka::Producer
• commitAsync() : RdKafka::KafkaConsumer
• commitSync() : RdKafka::KafkaConsumer
• committed() : RdKafka::KafkaConsumer
• consume() : RdKafka::Consumer , RdKafka::KafkaConsumer , RdKafka::Queue
• consume_callback() : RdKafka::Consumer
• consume_cb() : RdKafka::ConsumeCb
• controllerid() : RdKafka::Handle
• create() : RdKafka::Conf , RdKafka::Consumer , RdKafka::Error , RdKafka::Headers , RdKafka::KafkaConsumer , RdKafka::Producer , RdKafka::Queue , RdKafka::Topic , RdKafka::TopicPartition

- d -

• destroy() : RdKafka::TopicPartition
• dr_cb() : RdKafka::DeliveryReportCb
• dump() : RdKafka::Conf

- e -

• err() : RdKafka::Event , RdKafka::Headers::Header , RdKafka::Message , RdKafka::PartitionMetadata , RdKafka::TopicMetadata , RdKafka::TopicPartition
• errstr() : RdKafka::Message
• event_cb() : RdKafka::EventCb

- f -

• fac() : RdKafka::Event
• fatal() : RdKafka::Event
• fatal_error() : RdKafka::Handle
• flush() : RdKafka::Producer
• forward() : RdKafka::Queue

- g -

• get() : RdKafka::Conf , RdKafka::Headers
• get_all() : RdKafka::Headers
• get_last() : RdKafka::Headers
• get_partition_queue() : RdKafka::Handle
• get_watermark_offsets() : RdKafka::Handle
• groupMetadata() : RdKafka::KafkaConsumer

- h -

• Header() : RdKafka::Headers::Header
• headers() : RdKafka::Message
• host() : RdKafka::BrokerMetadata

- i -

• id() : RdKafka::BrokerMetadata , RdKafka::PartitionMetadata
• incremental_assign() : RdKafka::KafkaConsumer
• incremental_unassign() : RdKafka::KafkaConsumer
• init_transactions() : RdKafka::Producer
• io_event_enable() : RdKafka::Queue
• is_fatal() : RdKafka::Error
• is_retriable() : RdKafka::Error
• isrs() : RdKafka::PartitionMetadata

- k -

• key() : RdKafka::Headers::Header , RdKafka::Message
• key_len() : RdKafka::Message
• key_pointer() : RdKafka::Message

- l -

• latency() : RdKafka::Message
• leader() : RdKafka::PartitionMetadata
• len() : RdKafka::Message

- m -

• mem_free() : RdKafka::Handle
• mem_malloc() : RdKafka::Handle
• memberid() : RdKafka::Handle
• metadata() : RdKafka::Handle
• msg_opaque() : RdKafka::Message

- n -

• name() : RdKafka::Error , RdKafka::Handle , RdKafka::Topic

- o -

• oauthbearer_set_token() : RdKafka::Handle
• oauthbearer_set_token_failure() : RdKafka::Handle
• oauthbearer_token_refresh_cb() : RdKafka::OAuthBearerTokenRefreshCb
• offset() : RdKafka::Message , RdKafka::TopicPartition
• offset_commit_cb() : RdKafka::OffsetCommitCb
• offset_store() : RdKafka::Topic
• offsets_store() : RdKafka::KafkaConsumer
• offsetsForTimes() : RdKafka::Handle
• OffsetTail() : RdKafka::Consumer
• open_cb() : RdKafka::OpenCb
• operator=() : RdKafka::Headers::Header
• orig_broker_id() : RdKafka::Metadata
• orig_broker_name() : RdKafka::Metadata
• outq_len() : RdKafka::Handle

- p -

• partition() : RdKafka::Message , RdKafka::TopicPartition
• partition_available() : RdKafka::Topic
• partitioner_cb() : RdKafka::PartitionerCb , RdKafka::PartitionerKeyPointerCb
• partitions() : RdKafka::TopicMetadata
• pause() : RdKafka::Handle
• payload() : RdKafka::Message
• poll() : RdKafka::Handle , RdKafka::Queue
• port() : RdKafka::BrokerMetadata
• position() : RdKafka::KafkaConsumer
• produce() : RdKafka::Producer
• purge() : RdKafka::Producer

- q -

• query_watermark_offsets() : RdKafka::Handle

- r -

• rebalance_cb() : RdKafka::RebalanceCb
• rebalance_protocol() : RdKafka::KafkaConsumer
• remove() : RdKafka::Headers
• replicas() : RdKafka::PartitionMetadata
• resume() : RdKafka::Handle

- s -

• seek() : RdKafka::Consumer , RdKafka::KafkaConsumer
• send_offsets_to_transaction() : RdKafka::Producer
• set() : RdKafka::Conf
• set_engine_callback_data() : RdKafka::Conf
• set_log_queue() : RdKafka::Handle
• set_offset() : RdKafka::TopicPartition
• set_ssl_cert() : RdKafka::Conf
• severity() : RdKafka::Event
• size() : RdKafka::Headers
• socket_cb() : RdKafka::SocketCb
• ssl_cert_verify_cb() : RdKafka::SslCertificateVerifyCb
• start() : RdKafka::Consumer
• status() : RdKafka::Message
• stop() : RdKafka::Consumer
• str() : RdKafka::Error , RdKafka::Event
• subscribe() : RdKafka::KafkaConsumer
• subscription() : RdKafka::KafkaConsumer

- t -

• throttle_time() : RdKafka::Event
• timestamp() : RdKafka::Message
• topic() : RdKafka::Message , RdKafka::TopicMetadata , RdKafka::TopicPartition
• topic_name() : RdKafka::Message
• topics() : RdKafka::Metadata
• txn_requires_abort() : RdKafka::Error
• type() : RdKafka::Event

- u -

• unassign() : RdKafka::KafkaConsumer
• unsubscribe() : RdKafka::KafkaConsumer

- v -

• value() : RdKafka::Headers::Header
• value_size() : RdKafka::Headers::Header
• value_string() : RdKafka::Headers::Header

- y -

• yield() : RdKafka::Handle