Sha256: 85e8bb97f5aabb62f942a2f418cc9f3220986191297563c338fd05f4c5e4506c
Contents?: true
Size: 1.12 KB
Versions: 11
Compression:
Stored size: 1.12 KB
Contents
require "spec_helper"
describe Rdkafka::Config do
it "should store configuration" do
config = Rdkafka::Config.new
config[:"key"] = 'value'
expect(config[:"key"]).to eq 'value'
end
it "should use default configuration" do
config = Rdkafka::Config.new
expect(config[:"api.version.request"]).to eq true
end
it "should create a consumer with valid config" do
expect(rdkafka_config.consumer).to be_a Rdkafka::Consumer
end
it "should raise an error when creating a consumer with invalid config" do
config = Rdkafka::Config.new('invalid.key' => 'value')
expect {
config.consumer
}.to raise_error(Rdkafka::Config::ConfigError, "No such configuration property: \"invalid.key\"")
end
it "should create a producer with valid config" do
expect(rdkafka_config.producer).to be_a Rdkafka::Producer
end
it "should raise an error when creating a producer with invalid config" do
config = Rdkafka::Config.new('invalid.key' => 'value')
expect {
config.producer
}.to raise_error(Rdkafka::Config::ConfigError, "No such configuration property: \"invalid.key\"")
end
end
Version data entries
11 entries across 11 versions & 1 rubygems