We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a64ecee commit 19ae726Copy full SHA for 19ae726
spec/functional/topic_management_spec.rb
@@ -12,14 +12,11 @@
12
13
example "deleting topics" do
14
topic = generate_topic_name
15
- kafka.create_topic(topic, num_partitions: 3)
16
+ kafka.create_topic(topic, num_partitions: 3)
17
expect(kafka.partitions_for(topic)).to eq 3
18
- kafka.delete_topic(topic)
19
- kafka.instance_variable_get(:@cluster).mark_as_stale!
20
21
- expect do
22
- kafka.partitions_for(topic)
23
- end.to raise_error(Kafka::LeaderNotAvailable)
+ kafka.delete_topic(topic)
+ expect(kafka.has_topic?(topic)).to eql(false)
24
end
25
0 commit comments