Sha256: 7b99d5bd7f839e55ab27c07380386d60e709b889edbdaceb2ec6b9a3259b1785
Contents?: true
Size: 473 Bytes
Versions: 2
Compression:
Stored size: 473 Bytes
Contents
require "spec_helper" describe Rdkafka::Producer::DeliveryReport do subject { Rdkafka::Producer::DeliveryReport.new(2, 100, "topic", "error") } 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 error" do expect(subject.error).to eq "error" end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
karafka-rdkafka-0.12.4 | spec/rdkafka/producer/delivery_report_spec.rb |
karafka-rdkafka-0.12.3 | spec/rdkafka/producer/delivery_report_spec.rb |