Skip to content

python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer #2650

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

Merged
merged 8 commits into from
Jun 23, 2025

Conversation

dpkp
Copy link
Owner

@dpkp dpkp commented Jun 23, 2025

Builds on @rdiomar's work in #119 :

$ python -m kafka.producer -b 127.0.0.1:9092 -t "hello"
yo dude
what's up?

# Meanwhile, in another terminal...
$ python -m kafka.consumer -b 127.0.0.1:9092 -t "hello" -g "analytics"
yo dude
what's up?

Adding kafka.admin to the mix:

$ python -m kafka.admin -b 127.0.0.1:9092 cluster describe
{'brokers': [{'host': 'localhost', 'node_id': 0, 'port': 9092, 'rack': None}],
 'cluster_id': 'xxx-yyy',
 'controller_id': 0,
 'throttle_time_ms': 0}

@dpkp dpkp changed the title python -m __main__ interfaces for kafka.admin, kafka.consumer, kafka.producer python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer Jun 23, 2025
@dpkp dpkp merged commit 6f6a696 into master Jun 23, 2025
18 checks passed
@dpkp dpkp deleted the dpkp/kafka-admin-console-commands branch June 23, 2025 22:08
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant