Method List

Classes Methods Files

Search:

#== Rdkafka::RdkafkaError
#== Rdkafka::Consumer::Partition
#== Rdkafka::Consumer::TopicPartitionList
#[] Rdkafka::Config
#[]= Rdkafka::Config
#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
#broker_message Rdkafka::RdkafkaError
#brokers Rdkafka::Metadata
#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
#committed Rdkafka::Consumer
#configs Rdkafka::Admin::ConfigResourceBindingResult
#configs_count Rdkafka::Admin::ConfigResourceBindingResult
#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::DescribeConfigsHandle
#create_result Rdkafka::Admin::CreatePartitionsHandle
#create_result Rdkafka::Admin::IncrementalAlterConfigsHandle
#create_topic Rdkafka::Admin
#default Rdkafka::Admin::ConfigBindingResult
#delete_acl Rdkafka::Admin
#delete_group Rdkafka::Admin
#delete_topic Rdkafka::Admin
#deleted_acls Rdkafka::Admin::DeleteAclReport
#describe_acl Rdkafka::Admin
#describe_configs Rdkafka::Admin
describe_errors Rdkafka::Admin
#each Rdkafka::Consumer
#each_batch Rdkafka::Consumer
#empty? Rdkafka::Consumer::TopicPartitionList
ensure_ffi_running Rdkafka::Callbacks
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::Callbacks::DescribeConfigsResult
#error_string Rdkafka::Callbacks::IncrementalAlterConfigsResult
#error_string Rdkafka::Admin::AclBindingResult
#error_string Rdkafka::Admin::CreateTopicReport
#error_string Rdkafka::Admin::DeleteTopicReport
#error_string Rdkafka::Admin::DeleteGroupsReport
#events_poll Rdkafka::Consumer
#finalizer Rdkafka::Admin
#finalizer Rdkafka::Consumer
#flush Rdkafka::Producer
#get Rdkafka::Producer::PartitionsCountCache
#headers Rdkafka::Consumer::Message
#incremental_alter_configs Rdkafka::Admin
#initialize Rdkafka::ClosedConsumerError
#initialize Rdkafka::ClosedProducerError
#initialize Rdkafka::ClosedAdminError
#initialize Rdkafka::ClosedInnerError
#initialize Rdkafka::Config
#initialize Rdkafka::Metadata
#initialize Rdkafka::Callbacks::GroupResult
#initialize Rdkafka::Callbacks::DescribeConfigsResult
#initialize Rdkafka::Callbacks::IncrementalAlterConfigsResult
#initialize Rdkafka::AbstractHandle
#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::Admin::ConfigBindingResult
#initialize Rdkafka::Admin::DescribeConfigsReport
#initialize Rdkafka::Consumer::TopicPartitionList
#initialize Rdkafka::Producer::PartitionsCountCache
#initialize Rdkafka::Admin::ConfigResourceBindingResult
#initialize Rdkafka::Admin::IncrementalAlterConfigsReport
#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
#monotonic_now Rdkafka::Helpers::Time
#name Rdkafka::Admin
#name Rdkafka::Consumer
#name Rdkafka::Producer
#name Rdkafka::Admin::ConfigBindingResult
#name Rdkafka::Admin::ConfigResourceBindingResult
#oauthbearer_set_token Rdkafka::Helpers::OAuth
#oauthbearer_set_token_failure Rdkafka::Helpers::OAuth
oauthbearer_token_refresh_callback Rdkafka::Config
oauthbearer_token_refresh_callback= Rdkafka::Config
#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::DescribeConfigsHandle
#operation_name Rdkafka::Admin::CreatePartitionsHandle
#operation_name Rdkafka::Admin::IncrementalAlterConfigsHandle
#partition Rdkafka::Consumer::Message
#partition Rdkafka::Consumer::Partition
#partition Rdkafka::Producer::DeliveryReport
#partition_count Rdkafka::Producer
partitions_count_cache Rdkafka::Producer
partitions_count_cache= 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::DescribeConfigsHandle
#raise_error Rdkafka::Admin::CreatePartitionsHandle
#raise_error Rdkafka::Admin::IncrementalAlterConfigsHandle
#rdkafka_response Rdkafka::RdkafkaError
#rdkafka_response Rdkafka::Admin::CreateAclReport
#rdkafka_response_string Rdkafka::Admin::CreateAclReport
#read_only Rdkafka::Admin::ConfigBindingResult
register Rdkafka::AbstractHandle
remove Rdkafka::AbstractHandle
#resources Rdkafka::Admin::DescribeConfigsReport
#resources Rdkafka::Admin::IncrementalAlterConfigsReport
#result_error Rdkafka::Callbacks::GroupResult
#result_error Rdkafka::Callbacks::DescribeConfigsResult
#result_error Rdkafka::Callbacks::IncrementalAlterConfigsResult
#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
#results Rdkafka::Callbacks::DescribeConfigsResult
#results Rdkafka::Callbacks::IncrementalAlterConfigsResult
#results_count Rdkafka::Callbacks::DescribeConfigsResult
#results_count Rdkafka::Callbacks::IncrementalAlterConfigsResult
#resume Rdkafka::Consumer
#seek Rdkafka::Consumer
#seek_by Rdkafka::Consumer
#sensitive Rdkafka::Admin::ConfigBindingResult
#set Rdkafka::Producer::PartitionsCountCache
#set_topic_config Rdkafka::Producer
#start Rdkafka::Admin
#start Rdkafka::Consumer
#start Rdkafka::Producer
statistics_callback Rdkafka::Config
statistics_callback= Rdkafka::Config
#store_offset Rdkafka::Consumer
#subscribe Rdkafka::Consumer
#subscription Rdkafka::Consumer
#synonym Rdkafka::Admin::ConfigBindingResult
#synonyms Rdkafka::Admin::ConfigBindingResult
#timestamp Rdkafka::Consumer::Message
#to_h Rdkafka::Metadata::CustomFFIStruct
#to_h Rdkafka::Consumer::TopicPartitionList
#to_h Rdkafka::Producer::PartitionsCountCache
#to_s Rdkafka::RdkafkaError
#to_s Rdkafka::Consumer::Message
#to_s Rdkafka::Consumer::Partition
#to_s Rdkafka::Consumer::TopicPartitionList
#topic Rdkafka::Consumer::Message
#topic Rdkafka::Producer::DeliveryHandle
#topic_name Rdkafka::Producer::DeliveryReport
#topic_partition_list Rdkafka::RdkafkaTopicPartitionListError
#topics Rdkafka::Metadata
#truncate Rdkafka::Consumer::Message
#type Rdkafka::Admin::ConfigResourceBindingResult
#unlock Rdkafka::AbstractHandle
#unsubscribe Rdkafka::Consumer
#value Rdkafka::Admin::ConfigBindingResult
#wait Rdkafka::AbstractHandle