Method List

Classes Methods Files

Search:

#== Rdkafka::Consumer::Partition
#== Rdkafka::Consumer::TopicPartitionList
#== Rdkafka::RdkafkaError
#[] 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 Rdkafka::Callbacks::DeliveryCallback
call Rdkafka::Callbacks::BackgroundEventCallback
#call_delivery_callback Rdkafka::Opaque
#call_delivery_callback Rdkafka::Producer
#call_on_partitions_assigned Rdkafka::Opaque
#call_on_partitions_revoked Rdkafka::Opaque
#close Rdkafka::NativeKafka
#close Rdkafka::Admin
#close Rdkafka::Producer
#close Rdkafka::Consumer
#closed? Rdkafka::NativeKafka
#closed? Rdkafka::Consumer
#closed? Rdkafka::Admin
#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_group_metadata_pointer Rdkafka::Consumer
#consumer_rebalance_listener Rdkafka::Opaque
#count Rdkafka::Consumer::TopicPartitionList
#create_acl Rdkafka::Admin
create_acl_results_from_array Rdkafka::Callbacks::CreateAclResult
create_group_results_from_array Rdkafka::Callbacks::GroupResult
#create_partitions Rdkafka::Admin
#create_result Rdkafka::Admin::CreatePartitionsHandle
#create_result Rdkafka::Admin::DescribeConfigsHandle
#create_result Rdkafka::Admin::DescribeAclHandle
#create_result Rdkafka::AbstractHandle
#create_result Rdkafka::Admin::ListOffsetsHandle
#create_result Rdkafka::Producer::DeliveryHandle
#create_result Rdkafka::Admin::CreateAclHandle
#create_result Rdkafka::Admin::CreateTopicHandle
#create_result Rdkafka::Admin::DeleteTopicHandle
#create_result Rdkafka::Admin::DeleteAclHandle
#create_result Rdkafka::Admin::IncrementalAlterConfigsHandle
#create_result Rdkafka::Admin::DeleteGroupsHandle
#create_topic Rdkafka::Admin
create_topic_results_from_array Rdkafka::Callbacks::TopicResult
#default Rdkafka::Admin::ConfigBindingResult
#delete_acl Rdkafka::Admin
delete_acl_results_from_array Rdkafka::Callbacks::DeleteAclResult
#delete_group Rdkafka::Admin
#delete_topic Rdkafka::Admin
#deleted_acls Rdkafka::Admin::DeleteAclReport
#delivery_callback Rdkafka::Producer
#delivery_callback_arity Rdkafka::Producer
#describe_acl Rdkafka::Admin
#describe_configs Rdkafka::Admin
describe_errors Rdkafka::Admin
#each Rdkafka::Consumer
#each_batch Rdkafka::Consumer
#empty? Rdkafka::Consumer::TopicPartitionList
#enable_background_queue_io_events Rdkafka::Consumer
#enable_background_queue_io_events Rdkafka::NativeKafka
#enable_background_queue_io_events Rdkafka::Admin
#enable_background_queue_io_events Rdkafka::Producer
#enable_main_queue_io_events Rdkafka::NativeKafka
#enable_queue_io_events Rdkafka::Consumer
#enable_queue_io_events Rdkafka::Producer
#enable_queue_io_events Rdkafka::Admin
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::DescribeConfigsResult
#error_string Rdkafka::Callbacks::DeleteAclResult
#error_string Rdkafka::Callbacks::CreateAclResult
#error_string Rdkafka::Callbacks::IncrementalAlterConfigsResult
#error_string Rdkafka::Callbacks::DescribeAclResult
#error_string Rdkafka::Admin::CreateTopicReport
#error_string Rdkafka::Callbacks::GroupResult
#error_string Rdkafka::Admin::DeleteGroupsReport
#error_string Rdkafka::Admin::AclBindingResult
#error_string Rdkafka::Callbacks::TopicResult
#error_string Rdkafka::Callbacks::ListOffsetsResult
#error_string Rdkafka::Admin::DeleteTopicReport
#events_poll Rdkafka::Consumer
#events_poll_nb Rdkafka::Consumer
#events_poll_nb_each Rdkafka::Consumer
#events_poll_nb_each Rdkafka::Producer
#events_poll_nb_each Rdkafka::Admin
#finalizer Rdkafka::NativeKafka
#flush Rdkafka::Producer
from_native Rdkafka::Consumer::Headers
from_native_tpl Rdkafka::Consumer::TopicPartitionList
#get Rdkafka::Producer::PartitionsCountCache
#headers Rdkafka::Consumer::Message
#incremental_alter_configs Rdkafka::Admin
#initialize Rdkafka::Admin::DescribeConfigsReport
#initialize Rdkafka::Producer
#initialize Rdkafka::Admin::CreateAclReport
#initialize Rdkafka::Admin::ConfigBindingResult
#initialize Rdkafka::Metadata
#initialize Rdkafka::Admin::DeleteTopicReport
#initialize Rdkafka::Callbacks::ListOffsetsResult
#initialize Rdkafka::Producer::PartitionsCountCache
#initialize Rdkafka::Consumer
#initialize Rdkafka::Callbacks::IncrementalAlterConfigsResult
#initialize Rdkafka::Config
#initialize Rdkafka::Admin::CreateTopicReport
#initialize Rdkafka::Consumer::Partition
#initialize Rdkafka::Admin::ConfigResourceBindingResult
#initialize Rdkafka::ClosedInnerError
#initialize Rdkafka::Producer::DeliveryReport
#initialize Rdkafka::ClosedConsumerError
#initialize Rdkafka::RdkafkaTopicPartitionListError
#initialize Rdkafka::ClosedProducerError
#initialize Rdkafka::ClosedAdminError
#initialize Rdkafka::Admin::DeleteAclReport
#initialize Rdkafka::Admin::AclBindingResult
#initialize Rdkafka::RdkafkaError
#initialize Rdkafka::Admin
#initialize Rdkafka::Admin::IncrementalAlterConfigsReport
#initialize Rdkafka::Admin::ListOffsetsReport
#initialize Rdkafka::NativeKafka
#initialize Rdkafka::Callbacks::CreateAclResult
#initialize Rdkafka::Callbacks::GroupResult
#initialize Rdkafka::AbstractHandle
#initialize Rdkafka::Callbacks::TopicResult
#initialize Rdkafka::Admin::DescribeAclReport
#initialize Rdkafka::Consumer::Message
#initialize Rdkafka::Callbacks::DeleteAclResult
#initialize Rdkafka::Callbacks::DescribeAclResult
#initialize Rdkafka::Consumer::TopicPartitionList
#initialize Rdkafka::Admin::DeleteGroupsReport
#initialize Rdkafka::Callbacks::DescribeConfigsResult
#inspect Rdkafka::Consumer::Partition
#instance_name Rdkafka::RdkafkaError
#is_partition_eof? Rdkafka::RdkafkaError
#key Rdkafka::Consumer::Message
#label Rdkafka::Producer::DeliveryReport
#label Rdkafka::Producer::DeliveryHandle
#lag Rdkafka::Consumer
lib_extension Rdkafka::Bindings
#list_offsets Rdkafka::Admin
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
#matching_acls Rdkafka::Callbacks::DescribeAclResult
#matching_acls Rdkafka::Callbacks::DeleteAclResult
#matching_acls_count Rdkafka::Callbacks::DeleteAclResult
#matching_acls_count Rdkafka::Callbacks::DescribeAclResult
#member_id Rdkafka::Consumer
#message_prefix Rdkafka::RdkafkaError
#metadata Rdkafka::Admin
#monotonic_now Rdkafka::Helpers::Time
#monotonic_now_ms Rdkafka::Helpers::Time
#name Rdkafka::Admin::ConfigBindingResult
#name Rdkafka::Producer
#name Rdkafka::Consumer
#name Rdkafka::Admin::ConfigResourceBindingResult
#name Rdkafka::Admin
#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::Producer::DeliveryReport
#offset Rdkafka::Consumer::Message
#offset Rdkafka::Consumer::Partition
#offsets Rdkafka::Admin::ListOffsetsReport
#offsets_for_times Rdkafka::Consumer
opaques Rdkafka::Config
#operation_name Rdkafka::Producer::DeliveryHandle
#operation_name Rdkafka::Admin::DescribeAclHandle
#operation_name Rdkafka::Admin::DeleteTopicHandle
#operation_name Rdkafka::Admin::DescribeConfigsHandle
#operation_name Rdkafka::Admin::DeleteGroupsHandle
#operation_name Rdkafka::Admin::CreatePartitionsHandle
#operation_name Rdkafka::Admin::CreateTopicHandle
#operation_name Rdkafka::Admin::DeleteAclHandle
#operation_name Rdkafka::Admin::IncrementalAlterConfigsHandle
#operation_name Rdkafka::Admin::ListOffsetsHandle
#operation_name Rdkafka::Admin::CreateAclHandle
#operation_name Rdkafka::AbstractHandle
#partition Rdkafka::Consumer::Partition
#partition Rdkafka::Consumer::Message
#partition Rdkafka::Producer::DeliveryReport
#partition_count Rdkafka::Producer
partitioner Rdkafka::Bindings
partitions_count_cache Rdkafka::Producer
partitions_count_cache= Rdkafka::Producer
#pause Rdkafka::Consumer
#payload Rdkafka::Consumer::Message
#pending? Rdkafka::AbstractHandle
#poll Rdkafka::Consumer
#poll_nb Rdkafka::Consumer
#poll_nb_each Rdkafka::Consumer
#position Rdkafka::Consumer
process_create_acl Rdkafka::Callbacks::BackgroundEventCallback
process_create_partitions Rdkafka::Callbacks::BackgroundEventCallback
process_create_topic Rdkafka::Callbacks::BackgroundEventCallback
process_delete_acl Rdkafka::Callbacks::BackgroundEventCallback
process_delete_groups Rdkafka::Callbacks::BackgroundEventCallback
process_delete_topic Rdkafka::Callbacks::BackgroundEventCallback
process_describe_acl Rdkafka::Callbacks::BackgroundEventCallback
process_describe_configs Rdkafka::Callbacks::BackgroundEventCallback
process_incremental_alter_configs Rdkafka::Callbacks::BackgroundEventCallback
process_list_offsets Rdkafka::Callbacks::BackgroundEventCallback
#produce Rdkafka::Producer
#producer Rdkafka::Config
#producer Rdkafka::Opaque
#purge Rdkafka::Producer
#query_watermark_offsets Rdkafka::Consumer
#queue_size Rdkafka::Producer
#raise_error Rdkafka::Admin::CreatePartitionsHandle
#raise_error Rdkafka::Admin::DeleteGroupsHandle
#raise_error Rdkafka::Admin::ListOffsetsHandle
#raise_error Rdkafka::Admin::DescribeAclHandle
#raise_error Rdkafka::Admin::DescribeConfigsHandle
#raise_error Rdkafka::Admin::DeleteTopicHandle
#raise_error Rdkafka::Admin::CreateAclHandle
#raise_error Rdkafka::Admin::CreateTopicHandle
#raise_error Rdkafka::AbstractHandle
#raise_error Rdkafka::Admin::DeleteAclHandle
#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::IncrementalAlterConfigsReport
#resources Rdkafka::Admin::DescribeConfigsReport
#result_count Rdkafka::Callbacks::ListOffsetsResult
#result_error Rdkafka::Callbacks::ListOffsetsResult
#result_error Rdkafka::Callbacks::DescribeConfigsResult
#result_error Rdkafka::Callbacks::IncrementalAlterConfigsResult
#result_error Rdkafka::Callbacks::DescribeAclResult
#result_error Rdkafka::Callbacks::CreateAclResult
#result_error Rdkafka::Callbacks::DeleteAclResult
#result_error Rdkafka::Callbacks::TopicResult
#result_error Rdkafka::Callbacks::GroupResult
#result_error Rdkafka::Admin::AclBindingResult
#result_infos Rdkafka::Callbacks::ListOffsetsResult
#result_name Rdkafka::Callbacks::GroupResult
#result_name Rdkafka::Callbacks::TopicResult
#result_name Rdkafka::Admin::DeleteTopicReport
#result_name Rdkafka::Admin::CreateTopicReport
#result_name Rdkafka::Admin::DeleteGroupsReport
#results Rdkafka::Callbacks::IncrementalAlterConfigsResult
#results Rdkafka::Callbacks::DescribeConfigsResult
#results_count Rdkafka::Callbacks::IncrementalAlterConfigsResult
#results_count Rdkafka::Callbacks::DescribeConfigsResult
#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::NativeKafka
#start Rdkafka::Producer
#start Rdkafka::Consumer
#start Rdkafka::Admin
statistics_callback Rdkafka::Config
statistics_callback= Rdkafka::Config
#store_offset Rdkafka::Consumer
#subscribe Rdkafka::Consumer
#subscription Rdkafka::Consumer
#synchronize Rdkafka::NativeKafka
#synonym Rdkafka::Admin::ConfigBindingResult
#synonyms Rdkafka::Admin::ConfigBindingResult
#timestamp Rdkafka::Consumer::Message
#to_h Rdkafka::Producer::PartitionsCountCache
#to_h Rdkafka::Metadata::CustomFFIStruct
#to_h Rdkafka::Consumer::TopicPartitionList
#to_native_tpl Rdkafka::Consumer::TopicPartitionList
#to_s Rdkafka::Consumer::Partition
#to_s Rdkafka::Consumer::Message
#to_s Rdkafka::Consumer::TopicPartitionList
#to_s Rdkafka::RdkafkaError
#topic Rdkafka::Producer::DeliveryHandle
#topic Rdkafka::Consumer::Message
#topic_name Rdkafka::Producer::DeliveryReport
#topic_partition_list Rdkafka::RdkafkaTopicPartitionListError
#topics Rdkafka::Metadata
#type Rdkafka::Admin::ConfigResourceBindingResult
#unlock Rdkafka::AbstractHandle
#unsubscribe Rdkafka::Consumer
#value Rdkafka::Admin::ConfigBindingResult
#wait Rdkafka::AbstractHandle
#with_inner Rdkafka::NativeKafka