-
Notifications
You must be signed in to change notification settings - Fork 1.4k
Minor cleanups #221
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
Minor cleanups #221
Conversation
not sure why the travis build didn't automatically get linked, but it passed: https://travis-ci.org/mumrah/kafka-python/jobs/34144266 |
This PR needs rebased |
rebased -- waiting on tests |
@@ -112,9 +112,9 @@ def fetch_last_known_offsets(self, partitions=None): | |||
|
|||
def get_or_init_offset_callback(resp): | |||
try: | |||
kafka.common.check_error(resp) |
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.
Not a big fan of static import check_error. :(
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.
trying to avoid the bare import kafka
(which is circular) . perhaps we should import kafka.common
instead?
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.
Sure, kafka.common is good. However, most problems I've seen with circular imports have arised from the "from X import Y" syntax.
…fka.consumer, etc
No description provided.