Skip to content

Commit 28884c8

Browse files
committed
Fix an issue with thread argument
1 parent b0c87ee commit 28884c8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/util.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ def start(self):
108108
self.stop()
109109

110110
self.active = Event()
111-
self.thread = Thread(target=self._timer, args=(self.active))
111+
self.thread = Thread(target=self._timer, args=(self.active,))
112112
self.thread.daemon = True # So the app exits when main thread exits
113113
self.thread.start()
114114

0 commit comments

Comments
 (0)