Skip to content

Commit fe7bc77

Browse files
abickydasch
andauthored
Apply suggestions from code review
Co-authored-by: Daniel Schierbeck <[email protected]>
1 parent cda7667 commit fe7bc77

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

spec/functional/consumer_group_spec.rb

+3-3
Original file line numberDiff line numberDiff line change
@@ -476,7 +476,7 @@ def call(cluster:, members:, partitions:)
476476
end
477477
end
478478

479-
joinined_consumers = []
479+
joined_consumers = []
480480
consumers = 2.times.map do |i|
481481
assignment_strategy = assignment_strategy_class.new(i + 1)
482482

@@ -485,9 +485,9 @@ def call(cluster:, members:, partitions:)
485485
consumer.subscribe(topic)
486486

487487
allow(consumer).to receive(:trigger_heartbeat).and_wrap_original do |m, *args|
488-
joinined_consumers |= [consumer]
488+
joined_consumers |= [consumer]
489489
# Wait until all the consumers try to join to prevent one consumer from processing all messages
490-
raise Kafka::HeartbeatError if joinined_consumers.size < consumers.size
490+
raise Kafka::HeartbeatError if joined_consumers.size < consumers.size
491491
m.call(*args)
492492
end
493493

0 commit comments

Comments
 (0)