Method List

Classes Methods Files

Search:

#== Rdkafka::RdkafkaError
#== Rdkafka::Consumer::Partition
#== Rdkafka::Consumer::TopicPartitionList
#[] Rdkafka::Config
#[] Rdkafka::Consumer::Headers::HashWithSymbolKeysTreatedLikeStrings
#[]= Rdkafka::Config
#abort_transaction Rdkafka::Producer
#abortable? Rdkafka::RdkafkaError
#acls Rdkafka::Admin::DescribeAclReport
#add_topic Rdkafka::Consumer::TopicPartitionList
#add_topic_and_partitions_with_offsets Rdkafka::Consumer::TopicPartitionList
#admin Rdkafka::Config
#arity Rdkafka::Producer
#assign Rdkafka::Consumer
#assignment Rdkafka::Consumer
#assignment_lost? Rdkafka::Consumer
#begin_transaction Rdkafka::Producer
#broker_message Rdkafka::RdkafkaError
#brokers Rdkafka::Metadata
build Rdkafka::RdkafkaError
build_from_c Rdkafka::RdkafkaError
#call_delivery_callback Rdkafka::Producer
#close Rdkafka::Admin
#close Rdkafka::Consumer
#close Rdkafka::Producer
#closed? Rdkafka::Admin
#closed? Rdkafka::Consumer
#closed? Rdkafka::Producer
#cluster_id Rdkafka::Consumer
#code Rdkafka::RdkafkaError
#commit Rdkafka::Consumer
#commit_transaction Rdkafka::Producer
#committed Rdkafka::Consumer
#consumer Rdkafka::Config
#consumer_poll_set= Rdkafka::Config
#consumer_rebalance_listener= Rdkafka::Config
#count Rdkafka::Consumer::TopicPartitionList
#create_acl Rdkafka::Admin
create_group_results_from_array Rdkafka::Callbacks::GroupResult
#create_partitions Rdkafka::Admin
#create_result Rdkafka::AbstractHandle
#create_result Rdkafka::Admin::CreateAclHandle
#create_result Rdkafka::Admin::DeleteAclHandle
#create_result Rdkafka::Producer::DeliveryHandle
#create_result Rdkafka::Admin::CreateTopicHandle
#create_result Rdkafka::Admin::DeleteTopicHandle
#create_result Rdkafka::Admin::DescribeAclHandle
#create_result Rdkafka::Admin::DeleteGroupsHandle
#create_result Rdkafka::Admin::CreatePartitionsHandle
#create_topic Rdkafka::Admin
#delete_acl Rdkafka::Admin
#delete_group Rdkafka::Admin
#delete_topic Rdkafka::Admin
#deleted_acls Rdkafka::Admin::DeleteAclReport
#describe_acl Rdkafka::Admin
#each Rdkafka::Consumer
#each_batch Rdkafka::Consumer
#empty? Rdkafka::Consumer::TopicPartitionList
ensure_log_thread Rdkafka::Config
#err Rdkafka::Consumer::Partition
#error Rdkafka::Producer::DeliveryReport
error_callback Rdkafka::Config
error_callback= Rdkafka::Config
#error_string Rdkafka::Callbacks::GroupResult
#error_string Rdkafka::Admin::AclBindingResult
#error_string Rdkafka::Admin::CreateTopicReport
#error_string Rdkafka::Admin::DeleteTopicReport
#error_string Rdkafka::Admin::DeleteGroupsReport
#events_poll Rdkafka::Consumer
#fatal? Rdkafka::RdkafkaError
#finalizer Rdkafka::Admin
#finalizer Rdkafka::Consumer
#flush Rdkafka::Producer
#headers Rdkafka::Consumer::Message
#init_transactions Rdkafka::Producer
#initialize Rdkafka::ClosedConsumerError
#initialize Rdkafka::ClosedProducerError
#initialize Rdkafka::ClosedAdminError
#initialize Rdkafka::ClosedInnerError
#initialize Rdkafka::Config
#initialize Rdkafka::Metadata
#initialize Rdkafka::Callbacks::GroupResult
#initialize Rdkafka::Admin::CreateAclReport
#initialize Rdkafka::Admin::DeleteAclReport
#initialize Rdkafka::Admin::AclBindingResult
#initialize Rdkafka::Admin::CreateTopicReport
#initialize Rdkafka::Admin::DeleteTopicReport
#initialize Rdkafka::Admin::DescribeAclReport
#initialize Rdkafka::Admin::DeleteGroupsReport
#initialize Rdkafka::Consumer::TopicPartitionList
#inspect Rdkafka::Consumer::Partition
#is_partition_eof? Rdkafka::RdkafkaError
#key Rdkafka::Consumer::Message
#label Rdkafka::Producer::DeliveryHandle
#label Rdkafka::Producer::DeliveryReport
#lag Rdkafka::Consumer
log_queue Rdkafka::Config
logger Rdkafka::Config
logger= Rdkafka::Config
#matching_acl_host Rdkafka::Admin::AclBindingResult
#matching_acl_operation Rdkafka::Admin::AclBindingResult
#matching_acl_permission_type Rdkafka::Admin::AclBindingResult
#matching_acl_principal Rdkafka::Admin::AclBindingResult
#matching_acl_resource_name Rdkafka::Admin::AclBindingResult
#matching_acl_resource_pattern_type Rdkafka::Admin::AclBindingResult
#matching_acl_resource_type Rdkafka::Admin::AclBindingResult
#member_id Rdkafka::Consumer
#message_prefix Rdkafka::RdkafkaError
#metadata Rdkafka::Admin
#metadata Rdkafka::Consumer::Partition
#monotonic_now Rdkafka::Helpers::Time
#name Rdkafka::Consumer
#name Rdkafka::Producer
#offset Rdkafka::Consumer::Message
#offset Rdkafka::Consumer::Partition
#offset Rdkafka::Producer::DeliveryReport
#offsets_for_times Rdkafka::Consumer
#operation_name Rdkafka::AbstractHandle
#operation_name Rdkafka::Admin::CreateAclHandle
#operation_name Rdkafka::Admin::DeleteAclHandle
#operation_name Rdkafka::Producer::DeliveryHandle
#operation_name Rdkafka::Admin::CreateTopicHandle
#operation_name Rdkafka::Admin::DeleteTopicHandle
#operation_name Rdkafka::Admin::DescribeAclHandle
#operation_name Rdkafka::Admin::DeleteGroupsHandle
#operation_name Rdkafka::Admin::CreatePartitionsHandle
#partition Rdkafka::Consumer::Message
#partition Rdkafka::Consumer::Partition
#partition Rdkafka::Producer::DeliveryReport
#partition_count Rdkafka::Producer
#pause Rdkafka::Consumer
#payload Rdkafka::Consumer::Message
#pending? Rdkafka::AbstractHandle
#poll Rdkafka::Consumer
#position Rdkafka::Consumer
#produce Rdkafka::Producer
#producer Rdkafka::Config
#purge Rdkafka::Producer
#query_watermark_offsets Rdkafka::Consumer
#raise_error Rdkafka::AbstractHandle
#raise_error Rdkafka::Admin::CreateAclHandle
#raise_error Rdkafka::Admin::DeleteAclHandle
#raise_error Rdkafka::Admin::CreateTopicHandle
#raise_error Rdkafka::Admin::DeleteTopicHandle
#raise_error Rdkafka::Admin::DescribeAclHandle
#raise_error Rdkafka::Admin::DeleteGroupsHandle
#raise_error Rdkafka::Admin::CreatePartitionsHandle
#rdkafka_response Rdkafka::RdkafkaError
#rdkafka_response Rdkafka::Admin::CreateAclReport
#rdkafka_response_string Rdkafka::Admin::CreateAclReport
register Rdkafka::AbstractHandle
remove Rdkafka::AbstractHandle
#result_error Rdkafka::Callbacks::GroupResult
#result_error Rdkafka::Admin::AclBindingResult
#result_name Rdkafka::Callbacks::GroupResult
#result_name Rdkafka::Admin::CreateTopicReport
#result_name Rdkafka::Admin::DeleteTopicReport
#result_name Rdkafka::Admin::DeleteGroupsReport
#resume Rdkafka::Consumer
#retryable? Rdkafka::RdkafkaError
#seek Rdkafka::Consumer
#send_offsets_to_transaction Rdkafka::Producer
statistics_callback Rdkafka::Config
statistics_callback= Rdkafka::Config
#store_offset Rdkafka::Consumer
#subscribe Rdkafka::Consumer
#subscription Rdkafka::Consumer
#timestamp Rdkafka::Consumer::Message
#to_h Rdkafka::Metadata::CustomFFIStruct
#to_h Rdkafka::Consumer::TopicPartitionList
#to_s Rdkafka::RdkafkaError
#to_s Rdkafka::Consumer::Message
#to_s Rdkafka::Consumer::Partition
#to_s Rdkafka::Consumer::TopicPartitionList
#topic Rdkafka::Consumer::Message
#topic_name Rdkafka::Producer::DeliveryReport
#topic_partition_list Rdkafka::RdkafkaTopicPartitionListError
#topics Rdkafka::Metadata
#truncate Rdkafka::Consumer::Message
#unsubscribe Rdkafka::Consumer
validate! Rdkafka::RdkafkaError
#wait Rdkafka::AbstractHandle