# -t <topic name>
# -k <key id>
# -v <payload data as a string>
# -c <behave as a consumer>, -c -p will cause -c to assume the role
# -p <behave as a producer>, -p -c will cause -p to assume the role
# -d <number> delay sending or forwarding a message for <number seconds>
# -r <number> send or forward the same message <number> times
# -f <forward topic> forward messages from <watched topic> specied with -t <watched topic> to <forward topic>, if <forward topic> does not exist, it will be created

java -jar .\target\kafka_demo.jar -p -t celestial-stream -k test1 -v "some message"

java -jar .\target\kafka_demo.jar -p -t celestial-stream -k test1 -v "some message" -d 10

java -jar .\target\kafka_demo.jar -p -t celestial-stream -k test1 -v "some message" -r 3

java -jar .\target\kafka_demo.jar -c -t celestial-stream

java -jar .\target\kafka_demo.jar -t celestial-stream -f bridge