Contents

require "kafka"

ready "message serialization" do
  before do
    message = Kafka::Protocol::Message.new(
      value: "hello",
      key: "world",
    )

    @io = StringIO.new
    encoder = Kafka::Protocol::Encoder.new(@io)
    message.encode(encoder)

    @decoder = Kafka::Protocol::Decoder.new(@io)
  end

  go "decoding" do
    @io.rewind
    Kafka::Protocol::Message.decode(@decoder)
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
ruby-kafka-0.6.0.beta4	benchmarks/message_encoding.rb
ruby-kafka-0.6.0.beta3	benchmarks/message_encoding.rb
ruby-kafka-0.6.0.beta2	benchmarks/message_encoding.rb
ruby-kafka-0.6.0.beta1	benchmarks/message_encoding.rb
ruby-kafka-0.5.5	benchmarks/message_encoding.rb
ruby-kafka-0.5.4	benchmarks/message_encoding.rb
ruby-kafka-0.5.4.beta1	benchmarks/message_encoding.rb
ruby-kafka-0.5.3	benchmarks/message_encoding.rb
ruby-kafka-0.5.2	benchmarks/message_encoding.rb