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 65840b8 commit 77f1712Copy full SHA for 77f1712
spec/fuzz/consumer_group_spec.rb
@@ -3,14 +3,12 @@
3
let(:num_messages) { 10_000 }
4
let(:num_partitions) { 30 }
5
let(:num_consumers) { 10 }
6
- let(:topic) { "fuzz-consumer-group" }
+ let(:topic) { create_random_topic(num_partitions: num_partitions) }
7
let(:messages) { Set.new((1..num_messages).to_a) }
8
9
before do
10
logger.level = Logger::INFO
11
12
- KAFKA_CLUSTER.create_topic(topic, num_partitions: num_partitions, num_replicas: 1)
13
-
14
kafka = Kafka.new(seed_brokers: kafka_brokers, logger: logger)
15
producer = kafka.producer(max_buffer_size: 5000)
16
0 commit comments