summaryrefslogtreecommitdiffstats
path: root/ms/blueprintsprocessor/functions/message-prioritization/README.md
diff options
context:
space:
mode:
authorSingal, Kapil (ks220y) <ks220y@att.com>2020-12-15 19:02:17 -0500
committerKAPIL SINGAL <ks220y@att.com>2020-12-16 01:05:29 +0000
commit5844724ca96d08c3b752effdb10fd2586755912d (patch)
tree865f3f6f1736347c2305fdacf15f31e667e9283f /ms/blueprintsprocessor/functions/message-prioritization/README.md
parentf38e495d47e69b5203940e1f3eb76145c2a30e83 (diff)
Fixing typo in message-prioritization
Refactoring few POMs name tag Issue-ID: CCSDK-3053 Signed-off-by: Singal, Kapil (ks220y) <ks220y@att.com> Change-Id: I14447ea7f93efcc970213bbe7d42663cb87e33d7
Diffstat (limited to 'ms/blueprintsprocessor/functions/message-prioritization/README.md')
-rw-r--r--ms/blueprintsprocessor/functions/message-prioritization/README.md26
1 files changed, 26 insertions, 0 deletions
diff --git a/ms/blueprintsprocessor/functions/message-prioritization/README.md b/ms/blueprintsprocessor/functions/message-prioritization/README.md
new file mode 100644
index 000000000..cda43faca
--- /dev/null
+++ b/ms/blueprintsprocessor/functions/message-prioritization/README.md
@@ -0,0 +1,26 @@
+
+To Delete Topics
+------------------
+kafka-topics --zookeeper localhost:2181 --delete --topic prioritize-input-topic
+kafka-topics --zookeeper localhost:2181 --delete --topic prioritize-output-topic
+kafka-topics --zookeeper localhost:2181 --delete --topic test-prioritize-application-PriorityMessage-changelog
+
+Create Topics
+--------------
+
+kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-input-topic
+kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-output-topic
+
+To List topics
+----------------
+kafka-topics --list --bootstrap-server localhost:9092
+
+To publish message
+--------------------
+kafka-console-producer --broker-list localhost:9092 --topic prioritize-input-topic
+
+To Listen for Output
+----------------------
+kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-output-topic --from-beginning
+
+kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-input-topic --from-beginning