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.5.2	performance/profile.rb
ruby-kafka-0.5.2.beta3	performance/profile.rb
ruby-kafka-0.5.2.beta2	performance/profile.rb
ruby-kafka-0.5.2.beta1	performance/profile.rb
ruby-kafka-0.5.1	performance/profile.rb
ruby-kafka-0.5.1.beta2	performance/profile.rb
ruby-kafka-0.5.1.beta1	performance/profile.rb
ruby-kafka-0.4.4	performance/profile.rb
ruby-kafka-0.5.0	performance/profile.rb
ruby-kafka-0.5.0.beta6	performance/profile.rb
ruby-kafka-0.5.0.beta5	performance/profile.rb
ruby-kafka-0.5.0.beta4	performance/profile.rb
ruby-kafka-0.5.0.beta3	performance/profile.rb
ruby-kafka-0.5.0.beta2	performance/profile.rb
ruby-kafka-0.4.3	performance/profile.rb
ruby-kafka-0.4.2	performance/profile.rb
ruby-kafka-0.4.1	performance/profile.rb
ruby-kafka-0.4.0	performance/profile.rb
ruby-kafka-0.4.0.beta1	performance/profile.rb
ruby-kafka-0.3.18.beta2	performance/profile.rb