-
Notifications
You must be signed in to change notification settings - Fork 914
kafkatest, refactoring, and bug fixes #1
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
This is used to run the Kafka client tests
"\n" | ||
".. py:function:: on_commit(consumer, err, partitions)\n" | ||
"\n" | ||
" :param Consumer consumer: Consumer instance.\n" |
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.
I can't remember if passing the consumer instance as part of the callback came up before. I checked and we have it elsewhere. Is this valuable? Often in Python you just grab what you need via closure.
LGTM. Also validated unit and integration tests against current librdkafka master since we don't have automated testing here yet. |
Initial Go client for API review
@edenhill Just filing this so I can leave comments. We can always close this and push updates directly