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 287590e commit 457316aCopy full SHA for 457316a
spec/fuzz/consumer_group_spec.rb
@@ -11,11 +11,10 @@
11
logger.level = Logger::INFO
12
13
kafka = Kafka.new(seed_brokers: kafka_brokers, logger: logger)
14
- producer = kafka.producer(max_buffer_size: 5000)
+ producer = kafka.producer(max_buffer_size: num_messages)
15
16
messages.each do |i|
17
producer.produce(i.to_s, topic: topic, partition: i % num_partitions)
18
- producer.deliver_messages if i % 3000 == 0
19
end
20
21
producer.deliver_messages
0 commit comments