Skip to content

Commit 4727fb1

Browse files
authored
Fix early return in NativeKafka#start (#437)
I think this was a typo, and could potentially lead to creating multiple polling threads.
1 parent 9323e50 commit 4727fb1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/rdkafka/native_kafka.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def initialize(inner, run_polling_thread:, opaque:, auto_start: true)
3737

3838
def start
3939
synchronize do
40-
@return if @started
40+
return if @started
4141

4242
@started = true
4343

0 commit comments

Comments
 (0)