Contents

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

require "kafka"

logger = Logger.new(STDOUT)
logger.level = Logger::INFO
logger.formatter = ->(_, _, _, msg) { msg }

STDOUT.sync = true

$kafka = Kafka.new(
  logger: logger,
  seed_brokers: ENV.fetch("HEROKU_KAFKA_URL"),
  ssl_ca_cert: ENV.fetch("HEROKU_KAFKA_TRUSTED_CERT"),
  ssl_client_cert: ENV.fetch("HEROKU_KAFKA_CLIENT_CERT"),
  ssl_client_cert_key: ENV.fetch("HEROKU_KAFKA_CLIENT_CERT_KEY"),
)

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
ruby-kafka-0.5.2	ci/init.rb
ruby-kafka-0.5.2.beta3	ci/init.rb
ruby-kafka-0.5.2.beta2	ci/init.rb
ruby-kafka-0.5.2.beta1	ci/init.rb
ruby-kafka-0.5.1	ci/init.rb
ruby-kafka-0.5.1.beta2	ci/init.rb
ruby-kafka-0.5.1.beta1	ci/init.rb
ruby-kafka-0.4.4	ci/init.rb
ruby-kafka-0.5.0	ci/init.rb
ruby-kafka-0.5.0.beta6	ci/init.rb
ruby-kafka-0.5.0.beta5	ci/init.rb
ruby-kafka-0.5.0.beta4	ci/init.rb
ruby-kafka-0.5.0.beta3	ci/init.rb
ruby-kafka-0.5.0.beta2	ci/init.rb
ruby-kafka-0.4.3	ci/init.rb