Method List

Classes Methods Files

Search:

#== KafkaSyrup::Protocol::Message
#== KafkaSyrup::Protocol::MessageSet
#== KafkaSyrup::Protocol::Base
#add_broker KafkaSyrup::Protocol::MetadataResponse
#add_message KafkaSyrup::Protocol::ProduceRequest::Partition
#add_message KafkaSyrup::Protocol::FetchResponse::Partition
#add_partition KafkaSyrup::Protocol::FetchRequest::Topic
#add_partition KafkaSyrup::Protocol::ProduceResponse::Topic
#add_partition KafkaSyrup::Protocol::OffsetResponse::Topic
#add_partition KafkaSyrup::Protocol::OffsetRequest::Topic
#add_partition KafkaSyrup::Protocol::MetadataResponse::Topic
#add_partition KafkaSyrup::Protocol::ProduceRequest::Topic
#add_partition KafkaSyrup::Protocol::FetchResponse::Topic
#add_topic KafkaSyrup::Protocol::OffsetRequest
#add_topic KafkaSyrup::Protocol::MetadataResponse
#add_topic KafkaSyrup::Protocol::ProduceResponse
#add_topic KafkaSyrup::Protocol::ProduceRequest
#add_topic KafkaSyrup::Protocol::FetchRequest
#add_topic KafkaSyrup::Protocol::FetchResponse
#add_topic KafkaSyrup::Protocol::OffsetResponse
#api_key KafkaSyrup::Protocol::Request
api_key KafkaSyrup::Protocol::Request
#api_version KafkaSyrup::Protocol::Request
#broker KafkaSyrup::PartitionConsumer
#brokers KafkaSyrup::TopicProducer
#brokers KafkaSyrup::Configuration
brokers KafkaSyrup
#brokers KafkaSyrup::Protocol::MetadataResponse
#client_id KafkaSyrup::Protocol::Request
#code KafkaSyrup::Protocol::MetadataResponse::Topic
#code KafkaSyrup::Protocol::MetadataResponse::Partition
#code KafkaSyrup::Protocol::FetchResponse::Partition
#code KafkaSyrup::Protocol::OffsetResponse::Partition
#code KafkaSyrup::Protocol::ProduceResponse::Partition
#commit KafkaSyrup::TopicConsumer
#commit_mode KafkaSyrup::TopicConsumer
config KafkaSyrup
#config KafkaSyrup::Protocol::Base
configure KafkaSyrup
#consume_max_bytes KafkaSyrup::Configuration
#consume_max_wait_time KafkaSyrup::Configuration
#consume_min_bytes KafkaSyrup::Configuration
#consumer_id KafkaSyrup::TopicConsumer
#control_queue KafkaSyrup::PartitionConsumer
#control_queues KafkaSyrup::TopicConsumer
#correlation_id KafkaSyrup::Protocol::Response
#correlation_id KafkaSyrup::Protocol::Request
#crc KafkaSyrup::Protocol::Message
#current_registration_info KafkaSyrup::TopicConsumer
#decode KafkaSyrup::Protocol::Base
decode KafkaSyrup::Protocol::FetchResponse::Partition
decode KafkaSyrup::Protocol::MetadataResponse::Partition
#decode KafkaSyrup::Protocol::MetadataResponse
decode KafkaSyrup::Protocol::MetadataResponse::Broker
#decode KafkaSyrup::Protocol::Response
#decode KafkaSyrup::Protocol::OffsetResponse
decode KafkaSyrup::Protocol::ProduceResponse::Topic
#decode KafkaSyrup::Protocol::ProduceResponse
decode KafkaSyrup::Protocol::OffsetResponse::Topic
decode KafkaSyrup::Protocol::FetchResponse::Topic
decode KafkaSyrup::Protocol::ProduceResponse::Partition
decode KafkaSyrup::Protocol::OffsetResponse::Partition
#decode KafkaSyrup::Protocol::FetchResponse
decode KafkaSyrup::Protocol::MetadataResponse::Topic
#defaults KafkaSyrup::Protocol::MetadataResponse
#defaults KafkaSyrup::Protocol::ProduceRequest
#defaults KafkaSyrup::Protocol::FetchResponse
#defaults KafkaSyrup::Protocol::OffsetResponse
#defaults KafkaSyrup::TopicConsumer
#defaults KafkaSyrup::Protocol::Base
#defaults KafkaSyrup::Protocol::FetchRequest
#defaults KafkaSyrup::Protocol::OffsetRequest
#defaults KafkaSyrup::Protocol::MessageSet
#defaults KafkaSyrup::Protocol::ProduceResponse
#encode KafkaSyrup::Protocol::FetchResponse::Topic
#encode KafkaSyrup::Protocol::ProduceRequest
#encode KafkaSyrup::Protocol::ProduceResponse::Partition
#encode KafkaSyrup::Protocol::ProduceResponse::Topic
#encode KafkaSyrup::Protocol::OffsetRequest::Topic
#encode KafkaSyrup::Protocol::FetchResponse::Partition
#encode KafkaSyrup::Protocol::OffsetResponse::Partition
#encode KafkaSyrup::Protocol::FetchRequest::Partition
#encode KafkaSyrup::Protocol::MetadataRequest
#encode KafkaSyrup::Protocol::ProduceRequest::Partition
#encode KafkaSyrup::Protocol::OffsetResponse
#encode KafkaSyrup::Protocol::Base
#encode KafkaSyrup::Protocol::MetadataResponse::Topic
#encode KafkaSyrup::Protocol::FetchResponse
#encode KafkaSyrup::Protocol::OffsetRequest::Partition
#encode KafkaSyrup::Protocol::FetchRequest::Topic
#encode KafkaSyrup::Protocol::FetchRequest
#encode KafkaSyrup::Protocol::ProduceResponse
#encode KafkaSyrup::Protocol::OffsetRequest
#encode KafkaSyrup::Protocol::MetadataResponse::Broker
#encode KafkaSyrup::Protocol::Request
#encode KafkaSyrup::Protocol::Message
#encode KafkaSyrup::Protocol::MessageSet
#encode KafkaSyrup::Protocol::Response
#encode KafkaSyrup::Protocol::OffsetResponse::Topic
#encode KafkaSyrup::Protocol::ProduceRequest::Topic
#encode KafkaSyrup::Protocol::MetadataResponse
#encode KafkaSyrup::Protocol::MetadataResponse::Partition
#encoded KafkaSyrup::Protocol::Message
#fetch KafkaSyrup::TopicConsumer
#fetch KafkaSyrup::PartitionConsumer
#fetch_from_broker KafkaSyrup::PartitionConsumer
#get_available_offset KafkaSyrup::PartitionConsumer
get_metadata KafkaSyrup
#get_offset KafkaSyrup::TopicConsumer
#group KafkaSyrup::TopicConsumer
#group_path KafkaSyrup::TopicConsumer
#highwater_offset KafkaSyrup::Protocol::FetchResponse::Partition
#host KafkaSyrup::Protocol::MetadataResponse::Broker
#host KafkaSyrup::Broker
#id KafkaSyrup::Protocol::ProduceRequest::Partition
#id KafkaSyrup::Protocol::ProduceResponse::Partition
#id KafkaSyrup::Protocol::OffsetResponse::Partition
#id KafkaSyrup::Protocol::MetadataResponse::Partition
#id KafkaSyrup::Protocol::OffsetRequest::Partition
#id KafkaSyrup::Protocol::FetchResponse::Partition
#id KafkaSyrup::Protocol::FetchRequest::Partition
#initialize KafkaSyrup::PartitionConsumer
#initialize KafkaSyrup::Protocol::Request
#initialize KafkaSyrup::Protocol::Message
#initialize KafkaSyrup::TopicProducer
#initialize KafkaSyrup::TopicConsumer
#initialize KafkaSyrup::Protocol::MetadataRequest
#initialize KafkaSyrup::Protocol::Base
#initialize KafkaSyrup::Error
#initialize KafkaSyrup::Broker
#initialize KafkaSyrup::Protocol::MessageSet
#isr KafkaSyrup::Protocol::MetadataResponse::Partition
#key KafkaSyrup::Protocol::Message
#leader KafkaSyrup::Protocol::MetadataResponse::Partition
#load_args KafkaSyrup::Utils
#lock KafkaSyrup::PartitionConsumer
#lock KafkaSyrup::TopicConsumer
#log KafkaSyrup::Utils
#logger KafkaSyrup::Configuration
#max_bytes KafkaSyrup::PartitionConsumer
#max_bytes KafkaSyrup::TopicConsumer
#max_bytes KafkaSyrup::Protocol::FetchRequest::Partition
#max_bytes KafkaSyrup::Protocol::FetchRequest::Topic
#max_bytes KafkaSyrup::Protocol::FetchRequest
#max_offsets KafkaSyrup::Protocol::OffsetRequest::Partition
#max_wait_time KafkaSyrup::Protocol::FetchRequest
#membership_path KafkaSyrup::TopicConsumer
#message_set KafkaSyrup::Protocol::ProduceRequest::Partition
#message_set KafkaSyrup::Protocol::FetchResponse::Partition
#messages KafkaSyrup::PartitionConsumer
#messages KafkaSyrup::Protocol::MessageSet
#messages KafkaSyrup::TopicConsumer
#messages KafkaSyrup::Protocol::ProduceRequest::Partition
#messages KafkaSyrup::Protocol::FetchResponse::Partition
#min_bytes KafkaSyrup::Protocol::FetchRequest
#name KafkaSyrup::Protocol::OffsetRequest::Topic
#name KafkaSyrup::Protocol::ProduceResponse::Topic
#name KafkaSyrup::Protocol::MetadataResponse::Topic
#name KafkaSyrup::Protocol::OffsetResponse::Topic
#name KafkaSyrup::Protocol::FetchResponse::Topic
#name KafkaSyrup::Protocol::ProduceRequest::Topic
#name KafkaSyrup::Protocol::FetchRequest::Topic
#new_registration_info KafkaSyrup::TopicConsumer
#node KafkaSyrup::Protocol::MetadataResponse::Broker
#offset KafkaSyrup::Protocol::ProduceResponse::Partition
#offset KafkaSyrup::PartitionConsumer
#offset KafkaSyrup::Protocol::Message
#offset KafkaSyrup::Protocol::FetchRequest::Partition
#offset_mode KafkaSyrup::TopicConsumer
#offsets KafkaSyrup::Protocol::OffsetResponse::Partition
#offsets KafkaSyrup::TopicConsumer
#offsets_path KafkaSyrup::TopicConsumer
#opts KafkaSyrup::TopicProducer
#ownership_path KafkaSyrup::TopicConsumer
#partition KafkaSyrup::PartitionConsumer
#partitioner KafkaSyrup::TopicProducer
#partitions KafkaSyrup::Protocol::OffsetResponse::Topic
#partitions KafkaSyrup::Protocol::OffsetRequest::Topic
#partitions KafkaSyrup::Protocol::FetchResponse::Topic
#partitions KafkaSyrup::Protocol::FetchRequest::Topic
#partitions KafkaSyrup::Protocol::ProduceRequest::Topic
#partitions KafkaSyrup::TopicProducer
#partitions KafkaSyrup::Protocol::ProduceResponse::Topic
#partitions KafkaSyrup::TopicConsumer
#partitions KafkaSyrup::Protocol::MetadataResponse::Topic
#port KafkaSyrup::Broker
#port KafkaSyrup::Protocol::MetadataResponse::Broker
#produce_required_acks KafkaSyrup::Configuration
#produce_timeout KafkaSyrup::Configuration
raise_from_code KafkaSyrup::KafkaResponseErrors
read_array KafkaSyrup::Encoding
#rebalance KafkaSyrup::TopicConsumer
#refresh_metadata KafkaSyrup::PartitionConsumer
#refresh_metadata KafkaSyrup::TopicProducer
#register KafkaSyrup::TopicConsumer
#registered? KafkaSyrup::TopicConsumer
#registration_path KafkaSyrup::TopicConsumer
#release_partitions KafkaSyrup::TopicConsumer
#replicas KafkaSyrup::Protocol::MetadataResponse::Partition
#required_acks KafkaSyrup::Protocol::ProduceRequest
#retry_backoff KafkaSyrup::PartitionConsumer
#retry_backoff KafkaSyrup::Configuration
#send_message KafkaSyrup::TopicProducer
#send_request KafkaSyrup::Broker::Communications
#set_offset KafkaSyrup::TopicConsumer
#so_sndbuf KafkaSyrup::Configuration
#socket KafkaSyrup::Broker::Communications
#subscribers KafkaSyrup::TopicConsumer
#thread KafkaSyrup::PartitionConsumer
#threads KafkaSyrup::TopicConsumer
#time KafkaSyrup::Protocol::OffsetRequest::Partition
#timeout KafkaSyrup::Protocol::ProduceRequest
#topic KafkaSyrup::PartitionConsumer
#topic KafkaSyrup::TopicConsumer
#topic KafkaSyrup::TopicProducer
#topics KafkaSyrup::Protocol::OffsetResponse
#topics KafkaSyrup::Protocol::OffsetRequest
#topics KafkaSyrup::Protocol::FetchResponse
#topics KafkaSyrup::Protocol::FetchRequest
#topics KafkaSyrup::Protocol::ProduceRequest
#topics KafkaSyrup::Protocol::MetadataResponse
#topics KafkaSyrup::Protocol::ProduceResponse
#topics KafkaSyrup::Protocol::MetadataRequest
#uncommitted_partitions KafkaSyrup::TopicConsumer
#unregister KafkaSyrup::TopicConsumer
#value KafkaSyrup::Protocol::Message
#watcher KafkaSyrup::TopicConsumer
#with_defaults KafkaSyrup::Configuration
write_array KafkaSyrup::Encoding
#zk KafkaSyrup::TopicConsumer
#zookeeper_hosts KafkaSyrup::Configuration
#zookeeper_path KafkaSyrup::Configuration