Merge "kafka: fix python3 exception"
This commit is contained in:
commit
3b91f3d1cc
@ -191,7 +191,7 @@ class Connection(object):
|
||||
"""
|
||||
|
||||
def _raise_timeout(exc):
|
||||
raise driver_common.Timeout(exc.message)
|
||||
raise driver_common.Timeout(str(exc))
|
||||
|
||||
timer = driver_common.DecayingTimer(duration=timeout)
|
||||
timer.start()
|
||||
|
Loading…
x
Reference in New Issue
Block a user