Sha256: 72281b4ee49c7ad27deba2fea278d7eb2cb144fadabb8b6d04e05c0de7e047ba
Contents?: true
Size: 377 Bytes
Versions: 9
Compression:
Stored size: 377 Bytes
Contents
require "pry"
require "rspec"
require "rdkafka"
def rdkafka_config
config = {
:"bootstrap.servers" => "localhost:9092",
:"group.id" => "ruby_test",
:"enable.partition.eof" => false
}
if ENV["DEBUG_PRODUCER"]
config[:debug] = "broker,topic,msg"
elsif ENV["DEBUG_CONSUMER"]
config[:debug] = "cgrp,topic,fetch"
end
Rdkafka::Config.new(config)
end
Version data entries
9 entries across 9 versions & 1 rubygems