Module: KafkaSyrup::Protocol

Defined in:
lib/kafka_syrup/protocol.rb,
lib/kafka_syrup/protocol/base.rb,
lib/kafka_syrup/protocol/message.rb,
lib/kafka_syrup/protocol/request.rb,
lib/kafka_syrup/protocol/response.rb,
lib/kafka_syrup/protocol/message_set.rb,
lib/kafka_syrup/protocol/fetch_request.rb,
lib/kafka_syrup/protocol/fetch_response.rb,
lib/kafka_syrup/protocol/offset_request.rb,
lib/kafka_syrup/protocol/offset_response.rb,
lib/kafka_syrup/protocol/produce_request.rb,
lib/kafka_syrup/protocol/metadata_request.rb,
lib/kafka_syrup/protocol/produce_response.rb,
lib/kafka_syrup/protocol/metadata_response.rb

Defined Under Namespace

Classes: Base, FetchRequest, FetchResponse, Message, MessageSet, MetadataRequest, MetadataResponse, OffsetRequest, OffsetResponse, ProduceRequest, ProduceResponse, Request, Response

Constant Summary collapse

REPLICA_ID =
-1