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

Use aiokafka for creating topics and clean-up instead of kafka-python-ng #149

Open
nerdai opened this issue Jul 21, 2024 · 0 comments
Open
Labels
enhancement New feature or request P2

Comments

@nerdai
Copy link
Contributor

nerdai commented Jul 21, 2024

As of v 0.0.11, KafkaMessageQueue requires kafka-python-ng to use its admin client for creating topics and deleting topics/consumer groups. This is because the aiokafka package has some issues with resolving api version between the library and the Kafka broker.

Once this gets resolved in aiokafka we should use it exclusively for this integration.

Acceptance Criteria:

  1. use AioKafkaAdminClient for create_topic and clean_local methods
  2. use AioKafkaAdminClient in deregister_consumer to delete a topic if there would be no more consumers subscribed to the topic to which the deregistered consumer subscribed.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request P2
Projects
No open projects
Status: Todo
Development

No branches or pull requests

1 participant