Skip to content
This repository was archived by the owner on Jul 11, 2025. It is now read-only.

Conversation

@wbarnha
Copy link
Collaborator

@wbarnha wbarnha commented Mar 10, 2024

This adds ConsoleProducer/Consumer classes and 3 simple scripts for producing, consuming, and creating topics. This can be useful for testing and checking the state of things in kafka.

These commands are minimal right now, but more options/features can be added in the future.

How to use:

$ kp_create_topic -b 127.0.0.1:9092 -t "hello"
$ kp_producer -b 127.0.0.1:9092 -t "hello"
yo dude
what's up?

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

This change is Reviewable

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants