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