Skip to content

Commit e49b4b3

Browse files
committed
This spec stopped working at some point
Doesn't seem important, removing.
1 parent 7aadb07 commit e49b4b3

File tree

1 file changed

+0
-25
lines changed

1 file changed

+0
-25
lines changed

spec/functional/client_spec.rb

-25
Original file line numberDiff line numberDiff line change
@@ -156,31 +156,6 @@
156156
expect(message.key).to eq "xoxo"
157157
end
158158

159-
example "delivering a message to a topic that doesn't yet exist" do
160-
topic = "unknown-topic-#{SecureRandom.uuid}"
161-
now = Time.now
162-
163-
expect {
164-
Timecop.freeze(now) do
165-
kafka.deliver_message("yolo", topic: topic, key: "xoxo", partition: 0, headers: { hello: 'World' })
166-
end
167-
}.to raise_exception(Kafka::DeliveryFailed) {|exception|
168-
expect(exception.failed_messages).to eq [
169-
Kafka::PendingMessage.new(
170-
value: "yolo",
171-
key: "xoxo",
172-
headers: {
173-
hello: "World",
174-
},
175-
topic: topic,
176-
partition: 0,
177-
partition_key: nil,
178-
create_time: now
179-
)
180-
]
181-
}
182-
end
183-
184159
example "enumerating the messages in a topic" do
185160
values = (1..10).to_a
186161

0 commit comments

Comments
 (0)