Contents

# frozen_string_literal: true

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

48 entries across 48 versions & 3 rubygems

Version	Path
ruby-kafka-1.5.0	benchmarks/message_encoding.rb
ruby-kafka-aws-iam-1.4.5	benchmarks/message_encoding.rb
ruby-kafka-aws-iam-1.4.4	benchmarks/message_encoding.rb
ruby-kafka-aws-iam-1.4.3	benchmarks/message_encoding.rb
ruby-kafka-aws-iam-1.4.2	benchmarks/message_encoding.rb
ruby-kafka-aws-iam-1.4.1	benchmarks/message_encoding.rb
ruby-kafka-1.4.0	benchmarks/message_encoding.rb
ruby-kafka-temp-fork-0.0.2	benchmarks/message_encoding.rb
ruby-kafka-temp-fork-0.0.1	benchmarks/message_encoding.rb
ruby-kafka-1.3.0	benchmarks/message_encoding.rb
ruby-kafka-1.2.0	benchmarks/message_encoding.rb
ruby-kafka-1.1.0	benchmarks/message_encoding.rb
ruby-kafka-1.1.0.beta1	benchmarks/message_encoding.rb
ruby-kafka-1.0.0	benchmarks/message_encoding.rb
ruby-kafka-0.7.10	benchmarks/message_encoding.rb
ruby-kafka-0.7.9	benchmarks/message_encoding.rb
ruby-kafka-0.7.8	benchmarks/message_encoding.rb
ruby-kafka-0.7.7	benchmarks/message_encoding.rb
ruby-kafka-0.7.6	benchmarks/message_encoding.rb
ruby-kafka-0.7.6.beta2	benchmarks/message_encoding.rb