Skip to content

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