Skip to content
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

Does this library support the config option throttle_cb? #237

Closed
mtrienis opened this issue Aug 30, 2017 · 4 comments
Closed

Does this library support the config option throttle_cb? #237

mtrienis opened this issue Aug 30, 2017 · 4 comments
Assignees

Comments

@mtrienis
Copy link

Here is what my setup looks like:

yum list installed | grep librdka
librdkafka1.x86_64 0.9.5_confluent3.2.1-1.el6 @Confluent.dist
pip freeze | grep confluent
confluent-kafka==0.9.4
cat /etc/redhat-release
CentOS release 6.6 (Final)

And this is the error when I try to construct the producer?

KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Property "throttle_cb" must be set through dedicated .._set_..() function"}
@edenhill
Copy link
Contributor

The throttle callback is not yet exposed in the Python API.

@mtrienis
Copy link
Author

Thanks, do you think this is a simple extension? If it's trivial enough, I might be able to do a PR.

@edenhill
Copy link
Contributor

edenhill commented Sep 4, 2017

@mtrienis It should be straight forward, pretty much copying all occurrences of error_cb in confluent_kafka/src, tests, etc.

@rnpridgeon
Copy link
Contributor

The PR that fixes this has been merged into adminapi branch. Once the adminapi branch is merged to master it will be available.

#377

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

3 participants