Method List

Classes Methods Files

Search:

#add Kafka::FFI::Message::Header
#add Kafka::FFI::TopicPartitionList
#add_range Kafka::FFI::TopicPartitionList
#alter_configs Kafka::FFI::Client
#assign Kafka::FFI::Consumer
#assignment Kafka::FFI::Consumer
#assignments Kafka::Consumer
#broker Kafka::FFI::GroupInfo
#broker_id Kafka::FFI::Metadata
#broker_name Kafka::FFI::Metadata
#brokers Kafka::FFI::Metadata
#brokers_add Kafka::FFI::Client
by_ref Kafka::FFI::OpaquePointer
#client Kafka::Consumer
#client Kafka::Producer
#client_host Kafka::FFI::GroupMemberInfo
#client_id Kafka::FFI::GroupMemberInfo
#close Kafka::Consumer
#close Kafka::Producer
#close Kafka::FFI::Consumer
#cluster_id Kafka::FFI::Client
#code Kafka::ResponseError
#commit Kafka::Consumer
#commit Kafka::FFI::Consumer
#commit_message Kafka::FFI::Consumer
#committed Kafka::FFI::Consumer
#config Kafka::FFI::Client
#config_string Kafka::FFI::Event
#configs Kafka::FFI::Admin::ConfigResource
#consumer_poll Kafka::FFI::Consumer
#controller_id Kafka::FFI::Client
#copy Kafka::FFI::Message::Header
#copy Kafka::FFI::TopicPartitionList
#count Kafka::FFI::Message::Header
#create_partitions Kafka::FFI::Client
#create_topic Kafka::Admin
#create_topics Kafka::FFI::Client
#default_topic_conf_dup Kafka::FFI::Client
#del Kafka::FFI::TopicPartitionList
#del_by_idx Kafka::FFI::TopicPartitionList
#delete_topic Kafka::Admin
#delete_topics Kafka::FFI::Client
#describe_config Kafka::Admin
#describe_configs Kafka::FFI::Client
#destroy Kafka::Admin
#destroy Kafka::FFI::Event
#destroy Kafka::FFI::Queue
#destroy Kafka::FFI::Topic
#destroy Kafka::FFI::Client
#destroy Kafka::FFI::Config
#destroy Kafka::FFI::Message
#destroy Kafka::FFI::Metadata
#destroy Kafka::FFI::GroupList
#destroy Kafka::FFI::Admin::Result
#destroy Kafka::FFI::TopicConfig
#destroy Kafka::FFI::Message::Header
#destroy Kafka::FFI::Admin::NewTopic
#destroy Kafka::FFI::Admin::DeleteTopic
#destroy Kafka::FFI::Admin::AdminOptions
#destroy Kafka::FFI::Admin::NewPartitions
#destroy Kafka::FFI::TopicPartitionList
#destroy Kafka::FFI::Admin::ConfigResource
#detach_headers Kafka::FFI::Message
#done Kafka::Producer::DeliveryReport
#dup Kafka::FFI::Config
#dup Kafka::FFI::TopicConfig
#dup_filter Kafka::FFI::Config
#elements Kafka::FFI::TopicPartitionList
#empty? Kafka::FFI::TopicPartitionList
#error Kafka::FFI::Event
#error Kafka::FFI::Message
#error Kafka::FFI::GroupInfo
#error Kafka::FFI::TopicMetadata
#error Kafka::FFI::TopicPartition
#error Kafka::FFI::Admin::TopicResult
#error Kafka::FFI::PartitionMetadata
#error Kafka::Producer::DeliveryReport
#error Kafka::FFI::Admin::ConfigResource
#error? Kafka::Producer::DeliveryReport
#error_is_fatal Kafka::FFI::Event
#error_string Kafka::FFI::Event
#error_string Kafka::FFI::Admin::ConfigResource
#facility Kafka::FFI::Event::LogMessage
features Kafka::FFI
#find Kafka::FFI::TopicPartitionList
#flush Kafka::Producer
#flush Kafka::FFI::Producer
#forward Kafka::FFI::Queue
#free Kafka::FFI::Opaque
from_native Kafka::FFI::Client
from_native Kafka::FFI::Opaque
from_native Kafka::FFI::OpaquePointer
#get Kafka::Config
#get Kafka::FFI::Config
#get Kafka::FFI::TopicConfig
#get Kafka::FFI::Message::Header
#get_all Kafka::FFI::Message::Header
#get_background_queue Kafka::FFI::Client
#get_consumer_queue Kafka::FFI::Consumer
#get_last Kafka::FFI::Message::Header
#get_main_queue Kafka::FFI::Client
#get_partition_queue Kafka::FFI::Consumer
#get_results Kafka::FFI::Admin::Result
#get_watermark_offsets Kafka::FFI::Consumer
#group Kafka::FFI::GroupInfo
#group_list Kafka::FFI::Client
#groups Kafka::FFI::GroupList
#headers Kafka::FFI::Message
#host Kafka::FFI::BrokerMetadata
#id Kafka::FFI::BrokerMetadata
#id Kafka::FFI::PartitionMetadata
#in_sync_replicas Kafka::FFI::PartitionMetadata
inherited Kafka::FFI::OpaquePointer
#initialize Kafka::Admin
#initialize Kafka::ResponseError
#initialize Kafka::Config
#initialize Kafka::Poller
#initialize Kafka::Consumer
#initialize Kafka::Producer
#initialize Kafka::FFI::ConfigError
#initialize Kafka::FFI::Client
#initialize Kafka::FFI::Config
#initialize Kafka::FFI::Opaque
#initialize Kafka::FFI::Admin::Result
#initialize Kafka::FFI::OpaquePointer
#initialize Kafka::Producer::DeliveryReport
#internal? Kafka::ResponseError
#is_default Kafka::FFI::Admin::ConfigEntry
#is_read_only Kafka::FFI::Admin::ConfigEntry
#is_sensitive Kafka::FFI::Admin::ConfigEntry
#is_synonym Kafka::FFI::Admin::ConfigEntry
#key Kafka::FFI::ConfigError
#key Kafka::FFI::Message
#latency Kafka::FFI::Message
#latency Kafka::Producer::DeliveryReport
#leader Kafka::FFI::PartitionMetadata
#length Kafka::FFI::Queue
#level Kafka::FFI::Event::LogMessage
#log Kafka::FFI::Event
#member_assignment Kafka::FFI::GroupMemberInfo
#member_id Kafka::FFI::Consumer
#member_id Kafka::FFI::GroupMemberInfo
#member_metadata Kafka::FFI::GroupMemberInfo
#members Kafka::FFI::GroupInfo
#message Kafka::FFI::Event::LogMessage
#messages Kafka::FFI::Event
#metadata Kafka::Admin
#metadata Kafka::FFI::Client
#name Kafka::ResponseError
#name Kafka::FFI::Event
#name Kafka::FFI::Topic
#name Kafka::FFI::Client
#name Kafka::FFI::Admin::ConfigEntry
#name Kafka::FFI::Admin::TopicResult
#name Kafka::FFI::Admin::ConfigResource
new Kafka::FFI::Queue
new Kafka::FFI::Client
new Kafka::FFI::Config
new Kafka::FFI::Consumer
new Kafka::FFI::Producer
new Kafka::FFI::TopicConfig
new Kafka::FFI::Message::Header
new Kafka::FFI::Admin::NewTopic
new Kafka::FFI::Admin::DeleteTopic
new Kafka::FFI::Admin::AdminOptions
new Kafka::FFI::Admin::NewPartitions
new Kafka::FFI::TopicPartitionList
new Kafka::FFI::Admin::ConfigResource
#offset Kafka::FFI::Message
#offset Kafka::FFI::TopicPartition
#offset Kafka::Producer::DeliveryReport
#offsets_for_times Kafka::FFI::Client
#on_consume Kafka::Config
#on_delivery_report Kafka::Config
#on_error Kafka::Config
#on_log Kafka::Config
#on_offset_commit Kafka::Config
#on_stats Kafka::Config
#on_throttle Kafka::Config
#opaque Kafka::FFI::Message
#outq_len Kafka::FFI::Client
#partition Kafka::FFI::Message
#partition Kafka::FFI::TopicPartition
#partition Kafka::Producer::DeliveryReport
#partitions Kafka::FFI::TopicMetadata
#pause_partitions Kafka::FFI::Client
#payload Kafka::FFI::Message
#pointer Kafka::FFI::Opaque
#pointer Kafka::FFI::OpaquePointer
#poll Kafka::Consumer
#poll Kafka::FFI::Queue
#poll Kafka::FFI::Client
#poll_set_consumer Kafka::FFI::Consumer
#port Kafka::FFI::BrokerMetadata
#produce Kafka::Producer
#produce Kafka::FFI::Producer
#protocol Kafka::FFI::GroupInfo
#protocol_type Kafka::FFI::GroupInfo
#purge Kafka::FFI::Producer
#query_watermark_offsets Kafka::FFI::Client
#rd_kafka_AdminOptions_new Kafka::FFI
#rd_kafka_AlterConfigs Kafka::FFI
#rd_kafka_ConfigEntry_name Kafka::FFI
#rd_kafka_ConfigResource_new Kafka::FFI
#rd_kafka_ConfigSource_name Kafka::FFI
#rd_kafka_CreateTopics Kafka::FFI
#rd_kafka_DescribeConfigs Kafka::FFI
#rd_kafka_ResourceType_name Kafka::FFI
#rd_kafka_consume_start Kafka::FFI
#rd_kafka_subscribe Kafka::FFI
#received? Kafka::Producer::DeliveryReport
register Kafka::FFI::Opaque
remove Kafka::FFI::Opaque
#remove Kafka::FFI::Message::Header
#replicas Kafka::FFI::PartitionMetadata
#resume_partitions Kafka::FFI::Client
#seek Kafka::FFI::Topic
#set Kafka::Config
#set Kafka::FFI::Config
#set Kafka::FFI::TopicConfig
#set_background_event_cb Kafka::FFI::Config
#set_broker Kafka::FFI::Admin::AdminOptions
#set_closesocket_cb Kafka::FFI::Config
#set_config Kafka::FFI::Admin::NewTopic
#set_config Kafka::FFI::Admin::ConfigResource
#set_connect_cb Kafka::FFI::Config
#set_consume_cb Kafka::FFI::Config
#set_dr_msg_cb Kafka::FFI::Config
#set_error_cb Kafka::FFI::Config
#set_events Kafka::FFI::Config
#set_headers Kafka::FFI::Message
#set_log_cb Kafka::FFI::Config
#set_log_queue Kafka::FFI::Client
#set_oauthbearer_token_refresh_cb Kafka::FFI::Config
#set_offset Kafka::FFI::TopicPartitionList
#set_offset_commit_cb Kafka::FFI::Config
#set_open_cb Kafka::FFI::Config
#set_operation_timeout Kafka::FFI::Admin::AdminOptions
#set_partitioner_cb Kafka::FFI::TopicConfig
#set_rebalance_cb Kafka::FFI::Config
#set_replica_assignment Kafka::FFI::Admin::NewTopic
#set_replica_assignment Kafka::FFI::Admin::NewPartitions
#set_request_timeout Kafka::FFI::Admin::AdminOptions
#set_socket_cb Kafka::FFI::Config
#set_ssl_cert Kafka::FFI::Config
#set_ssl_cert_verify_cb Kafka::FFI::Config
#set_stats_cb Kafka::FFI::Config
#set_throttle_cb Kafka::FFI::Config
#set_validate_only Kafka::FFI::Admin::AdminOptions
#size Kafka::FFI::TopicPartitionList
#sort Kafka::FFI::TopicPartitionList
#source Kafka::FFI::Admin::ConfigEntry
#state Kafka::FFI::GroupInfo
#stats Kafka::FFI::Event
#stop Kafka::Poller
#subscribe Kafka::Consumer
#subscribe Kafka::FFI::Consumer
#subscription Kafka::FFI::Consumer
#successful? Kafka::Producer::DeliveryReport
#synonyms Kafka::FFI::Admin::ConfigEntry
#timestamp Kafka::FFI::Message
#to_ffi Kafka::Config
to_native Kafka::FFI::Opaque
to_native Kafka::FFI::OpaquePointer
#to_s Kafka::ResponseError
#to_s Kafka::FFI::Event::LogMessage
#topic Kafka::FFI::Client
#topic Kafka::FFI::Message
#topic Kafka::FFI::TopicMetadata
#topic Kafka::FFI::TopicPartition
#topic Kafka::Producer::DeliveryReport
#topic_partition Kafka::FFI::Event
#topic_partition_list Kafka::FFI::Event
#topics Kafka::FFI::Metadata
#type Kafka::FFI::Event
#type Kafka::FFI::Admin::ConfigResource
#unsubscribe Kafka::FFI::Consumer
#value Kafka::FFI::ConfigError
#value Kafka::FFI::Opaque
#value Kafka::FFI::Admin::ConfigEntry
version Kafka::FFI
#wait Kafka::Producer::DeliveryReport