Sha256: b289bd9fd62c7160683a3084e4eaa346fca3ad2467a14f4b252637ba64c53553
Contents?: true
Size: 797 Bytes
Versions: 33
Compression:
Stored size: 797 Bytes
Contents
require 'logstash-logger'
describe LogStashLogger::Device::Kafka do
include_context 'device'
let(:producer) { double("Poseidon::Producer") }
before(:each) do
allow(Poseidon::Producer).to receive(:new) { producer }
end
it "writes to a Kafka topic" do
expect(producer).to receive(:send_messages)
kafka_device.write "foo"
end
it "defaults the Kafka hosts to ['localhost:9092']" do
expect(kafka_device.hosts).to eq(['localhost:9092'])
end
it "defaults the Kafka topic to 'logstash'" do
expect(kafka_device.topic).to eq('logstash')
end
it "defaults the Kafka producer to 'logstash-logger'" do
expect(kafka_device.producer).to eq('logstash-logger')
end
it "defaults the Kafka backoff to 1" do
expect(kafka_device.backoff).to eq(1)
end
end
Version data entries
33 entries across 33 versions & 3 rubygems