Contents

$LOAD_PATH.unshift(File.expand_path("../../lib", __FILE__))
$LOAD_PATH.unshift(File.expand_path("../../spec", __FILE__))

require "kafka"
require "ruby-prof"
require "dotenv"
require "test_cluster"

Dotenv.load

# Number of times do iterate.
N = 10_000

KAFKA_CLUSTER = TestCluster.new
KAFKA_CLUSTER.start

logger = Logger.new(nil)

kafka = Kafka.new(
  seed_brokers: KAFKA_CLUSTER.kafka_hosts,
  client_id: "test",
  logger: logger,
)

producer = kafka.producer(
  max_buffer_size: 100_000,
)

RubyProf.start

N.times do
  producer.produce("hello", topic: "greetings")
end

result = RubyProf.stop
printer = RubyProf::FlatPrinter.new(result)
printer.print(STDOUT)

KAFKA_CLUSTER.stop

Version data entries

38 entries across 38 versions & 1 rubygems

Version	Path
ruby-kafka-0.3.18.beta1	performance/profile.rb
ruby-kafka-0.3.17	performance/profile.rb
ruby-kafka-0.3.16	performance/profile.rb
ruby-kafka-0.3.16.beta2	performance/profile.rb
ruby-kafka-0.3.16.beta1	performance/profile.rb
ruby-kafka-0.3.15	performance/profile.rb
ruby-kafka-0.3.15.beta3	performance/profile.rb
ruby-kafka-0.3.15.beta2	performance/profile.rb
ruby-kafka-0.3.15.beta1	performance/profile.rb
ruby-kafka-0.3.14	performance/profile.rb
ruby-kafka-0.3.13.beta4	performance/profile.rb
ruby-kafka-0.3.13.beta3	performance/profile.rb
ruby-kafka-0.3.13.beta2	performance/profile.rb
ruby-kafka-0.3.13.beta1	performance/profile.rb
ruby-kafka-0.3.12	performance/profile.rb
ruby-kafka-0.3.11	performance/profile.rb
ruby-kafka-0.3.10	performance/profile.rb
ruby-kafka-0.3.9	performance/profile.rb