Sha256: 142570cd43bedd1bc56be2544a194ca0619ff0f4131d642c1c76632e023d4231
Contents?: true
Size: 577 Bytes
Versions: 41
Compression:
Stored size: 577 Bytes
Contents
# frozen_string_literal: true
describe Rdkafka::Producer::DeliveryReport do
subject { Rdkafka::Producer::DeliveryReport.new(2, 100, "topic", -1) }
it "should get the partition" do
expect(subject.partition).to eq 2
end
it "should get the offset" do
expect(subject.offset).to eq 100
end
it "should get the topic_name" do
expect(subject.topic_name).to eq "topic"
end
it "should get the same topic name under topic alias" do
expect(subject.topic).to eq "topic"
end
it "should get the error" do
expect(subject.error).to eq -1
end
end
Version data entries
41 entries across 41 versions & 2 rubygems