-
Notifications
You must be signed in to change notification settings - Fork 1.5k
Fail-fast on timeout constraint violations during KafkaConsumer creation #986
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
saw that there are failures in travis. I'm taking a look at it. If you could provide instructions on how to run it locally with tox, that would be great. |
|
fixed - Another build has started. Monitoring. |
|
Can we drop support for python 2.6? I'd rather be able to use |
|
I like the idea of such errors. |
kafka/consumer/group.py
Outdated
| fetch_max_wait_ms = self.config['fetch_max_wait_ms'] | ||
| if request_timeout_ms <= session_timeout_ms: | ||
| raise KafkaConfigurationError( | ||
| "Request timeout (" + str(request_timeout_ms) + ") must be larger than session timeout (" + |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
"Request timeout (%s) must be larger than session timeout (%s)" % (request_timeout_ms, session_timeout_ms) is another alternative here
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
true, and better of course. fixing.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done, pushed fix.
|
fixed string interpolation according to comment. Travis running. |
|
Thanks! |
Related to #739