Method List
-
#<< Kafka::Batch
-
#batch Kafka::Producer
-
#calculate_checksum Kafka::Message
-
#checksum Kafka::Message
-
#connect Kafka::IO
-
#consume Kafka::Consumer
-
#disconnect Kafka::IO
-
#encode Kafka::Producer
-
#encode_request Kafka::Consumer
-
#encode_request Kafka::Producer
-
#encoded_request_size Kafka::Consumer
-
#fetch_latest_offset Kafka::Consumer
-
#host Kafka::IO
-
#initialize Kafka::Batch
-
#initialize Kafka::Producer
-
#initialize Kafka::Message
-
#initialize Kafka::Consumer
-
#loop Kafka::Consumer
-
#magic Kafka::Message
-
#max_size Kafka::Consumer
-
#messages Kafka::Batch
-
#offset Kafka::Consumer
-
parse_from Kafka::Message
-
#parse_message_set_from Kafka::Consumer
-
#partition Kafka::Consumer
-
#partition Kafka::Producer
-
#payload Kafka::Message
-
#polling Kafka::Consumer
-
#port Kafka::IO
-
#read Kafka::IO
-
#read_data_response Kafka::Consumer
-
#read_offsets_response Kafka::Consumer
-
#reconnect Kafka::IO
-
#request_type Kafka::Consumer
-
#send Kafka::Producer
-
#send_consume_request Kafka::Consumer
-
#send_offsets_request Kafka::Consumer
-
#socket Kafka::IO
-
to_s Kafka::ErrorCodes
-
#topic Kafka::Producer
-
#topic Kafka::Consumer
-
#valid? Kafka::Message
-
#write Kafka::IO