Skip to content
This repository has been archived by the owner on Aug 29, 2023. It is now read-only.

Switch to using the new KafkaAdminClient where appropriate #208

Open
jeffwidman opened this issue Jan 5, 2019 · 0 comments
Open

Switch to using the new KafkaAdminClient where appropriate #208

jeffwidman opened this issue Jan 5, 2019 · 0 comments

Comments

@jeffwidman
Copy link

Some of the code in this utility could be simplified by leveraging kafka-python's new KafkaAdminClient, for example the code for fetching consumer group offsets is very straightforward if you use https://kafka-python.readthedocs.io/en/master/apidoc/KafkaAdminClient.html#kafka.admin.KafkaAdminClient.list_consumer_group_offsets.

Note that this is a new class so the interfaces are a little unstable, particularly the ones that still return raw structs... but the ones that return more pythonically formatted data should generally be stable.

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

No branches or pull requests

1 participant