Method List

Classes Methods Files

Search:

#== Kafka::Protocol::Message
#array Kafka::Protocol::Decoder
#attributes Kafka::Protocol::Message
#brokers Kafka::Protocol::MetadataResponse
#buffer_size Kafka::Producer
#bytes Kafka::Protocol::Decoder
#clear Kafka::MessageBuffer
#clear_messages Kafka::MessageBuffer
#close Kafka::Client
#close Kafka::SocketWithTimeout
#close Kafka::Connection
#concat Kafka::MessageBuffer
connect Kafka::Broker
#connect Kafka::Connection
#connected? Kafka::Connection
decode Kafka::Protocol::ProduceResponse
decode Kafka::Protocol::MetadataResponse
#disconnect Kafka::Broker
#each Kafka::MessageBuffer
#each_partition Kafka::Protocol::ProduceResponse
#empty? Kafka::MessageBuffer
#encode Kafka::Protocol::Message
#encode Kafka::Protocol::ProduceRequest
#encode Kafka::Protocol::TopicMetadataRequest
#encode Kafka::Protocol::RequestMessage
encode_with Kafka::Protocol::Encoder
#error_code Kafka::Protocol::ProduceResponse::PartitionInfo
#fetch_metadata Kafka::Broker
#find_broker Kafka::Protocol::MetadataResponse
#find_leader_id Kafka::Protocol::MetadataResponse
#get_broker Kafka::BrokerPool
#get_leader_id Kafka::BrokerPool
#get_producer Kafka::Client
handle_error Kafka::Protocol
#host Kafka::Protocol::MetadataResponse::BrokerInfo
#initialize Kafka::Transmission
#initialize Kafka::MessageBuffer
#initialize Kafka::Protocol::RequestMessage
#initialize Kafka::SocketWithTimeout
#initialize Kafka::Partitioner
#initialize Kafka::Protocol::ProduceResponse::PartitionInfo
#initialize Kafka::Protocol::ProduceResponse::TopicInfo
#initialize Kafka::Protocol::Message
#initialize Kafka::Protocol::MetadataResponse
#initialize Kafka::Protocol::MetadataResponse::PartitionMetadata
#initialize Kafka::Connection
#initialize Kafka::BrokerPool
#initialize Kafka::Protocol::MetadataResponse::TopicMetadata
#initialize Kafka::Producer
#initialize Kafka::Client
#initialize Kafka::Protocol::ProduceResponse
#initialize Kafka::Broker
#initialize Kafka::Protocol::TopicMetadataRequest
#initialize Kafka::Protocol::Encoder
#initialize Kafka::Protocol::MetadataResponse::BrokerInfo
#initialize Kafka::Protocol::ProduceRequest
#initialize Kafka::Protocol::Decoder
#inspect Kafka::Protocol::MetadataResponse::BrokerInfo
#int16 Kafka::Protocol::Decoder
#int32 Kafka::Protocol::Decoder
#int64 Kafka::Protocol::Decoder
#int8 Kafka::Protocol::Decoder
#key Kafka::Protocol::Message
#leader Kafka::Protocol::MetadataResponse::PartitionMetadata
#mark_as_stale! Kafka::BrokerPool
#messages_for_topics Kafka::Protocol::ProduceRequest
new Kafka
#node_id Kafka::Protocol::MetadataResponse::BrokerInfo
#offset Kafka::Protocol::ProduceResponse::PartitionInfo
#partition Kafka::Protocol::ProduceResponse::PartitionInfo
#partition_error_code Kafka::Protocol::MetadataResponse::PartitionMetadata
#partition_for_key Kafka::Partitioner
#partition_id Kafka::Protocol::MetadataResponse::PartitionMetadata
#partitions Kafka::Protocol::MetadataResponse::TopicMetadata
#partitions Kafka::Protocol::ProduceResponse::TopicInfo
#partitions_for Kafka::Protocol::MetadataResponse
#partitions_for Kafka::BrokerPool
#port Kafka::Protocol::MetadataResponse::BrokerInfo
#produce Kafka::Producer
#produce Kafka::Broker
#read Kafka::Protocol::Decoder
#read Kafka::SocketWithTimeout
#request Kafka::Connection
#required_acks Kafka::Protocol::ProduceRequest
#requires_acks? Kafka::Protocol::ProduceRequest
#send_messages Kafka::Transmission
#send_messages Kafka::Producer
#set_encoding Kafka::SocketWithTimeout
#shutdown Kafka::BrokerPool
#shutdown Kafka::Producer
#size Kafka::MessageBuffer
#string Kafka::Protocol::Decoder
#timeout Kafka::Protocol::ProduceRequest
#to_h Kafka::MessageBuffer
#to_s Kafka::Connection
#to_s Kafka::Broker
#topic Kafka::Protocol::ProduceResponse::TopicInfo
#topic_error_code Kafka::Protocol::MetadataResponse::TopicMetadata
#topic_name Kafka::Protocol::MetadataResponse::TopicMetadata
#topics Kafka::Protocol::MetadataResponse
#topics Kafka::BrokerPool
#topics Kafka::Client
#topics Kafka::Protocol::ProduceResponse
#value Kafka::Protocol::Message
#write Kafka::Protocol::Encoder
#write Kafka::MessageBuffer
#write Kafka::SocketWithTimeout
#write_array Kafka::Protocol::Encoder
#write_bytes Kafka::Protocol::Encoder
#write_int16 Kafka::Protocol::Encoder
#write_int32 Kafka::Protocol::Encoder
#write_int64 Kafka::Protocol::Encoder
#write_int8 Kafka::Protocol::Encoder
#write_string Kafka::Protocol::Encoder