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

23 entries across 23 versions & 1 rubygems

Version	Path
ruby-kafka-0.4.2	ci/init.rb
ruby-kafka-0.4.1	ci/init.rb
ruby-kafka-0.4.0	ci/init.rb
ruby-kafka-0.4.0.beta1	ci/init.rb
ruby-kafka-0.3.18.beta2	ci/init.rb
ruby-kafka-0.3.18.beta1	ci/init.rb
ruby-kafka-0.3.17	ci/init.rb
ruby-kafka-0.3.16	ci/init.rb
ruby-kafka-0.3.16.beta2	ci/init.rb
ruby-kafka-0.3.16.beta1	ci/init.rb
ruby-kafka-0.3.15	ci/init.rb
ruby-kafka-0.3.15.beta3	ci/init.rb
ruby-kafka-0.3.15.beta2	ci/init.rb
ruby-kafka-0.3.15.beta1	ci/init.rb
ruby-kafka-0.3.14	ci/init.rb
ruby-kafka-0.3.13.beta4	ci/init.rb
ruby-kafka-0.3.13.beta3	ci/init.rb
ruby-kafka-0.3.13.beta2	ci/init.rb
ruby-kafka-0.3.13.beta1	ci/init.rb
ruby-kafka-0.3.12	ci/init.rb