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.

Sign up for GitHub

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

Jump to bottom

Question: how to get the consumer id assigned by Kafka? #1139

Closed
fra-luc opened this issue Jun 16, 2021 · 2 comments
Closed

Question: how to get the consumer id assigned by Kafka? #1139

fra-luc opened this issue Jun 16, 2021 · 2 comments
Assignees
@jliunyu
Labels
enhancement

Comments

@fra-luc
Copy link

fra-luc commented Jun 16, 2021

Is there a way to get the consumer id from the instance of the Consumer object after having subscribed to a Kafka topic?

Thanks!
@edenhill
Copy link
Contributor

librdkafka has a rd_kafka_memberid() function, but it is not exposed in the Python client.

Easy enough to add though.

@fra-luc
Copy link
Author

fra-luc commented Jun 16, 2021

Thank you!

@jliunyu jliunyu linked a pull request Jun 29, 2021 that will close this issue
Support rd_kafka_memberid() from python clients #1154
Closed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@jliunyu jliunyu

Labels
enhancement
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

Support rd_kafka_memberid() from python clients jliunyu/confluent-kafka-python
4 participants
@edenhill @jliunyu @fra-luc @nhaq-confluent