- Notifications
You must be signed in to change notification settings - Fork 934
Implement consume for DeserializingConsumer #1143
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
base: master
Are you sure you want to change the base?
Conversation
Factors out the parsing logic from DeserializingConsumer.poll() to reuse in consume().
| It looks like @charles-cooper hasn't signed our Contributor License Agreement, yet.
You can read and sign our full Contributor License Agreement here. Once you've signed reply with Appreciation of efforts, clabot |
I don't agree to the terms of this agreement. I am releasing my code as open source code under the Apache 2.0 license, which you can find at https://github.com/charles-cooper/confluent-kafka-python/blob/master/LICENSE.txt. You are free to accept or reject this pull request as you wish. |
| It looks like @charles-cooper hasn't signed our Contributor License Agreement, yet.
You can read and sign our full Contributor License Agreement here. Once you've signed reply with Appreciation of efforts, clabot |
| Oops, looks like I may have duplicated some work with #1085 |
| @charles-cooper thanks for your contribution, unfortunately things are very slow over here |
|
|
| this is still necessary , could we merge this Thanks |
| gentle ping @rayokota @pranavrth , thanks |
| gentle ping @rayokota , thanks |
Factors out the parsing logic from DeserializingConsumer.poll() to reuse
in consume().