ms/blueprintsprocessor/functions/message-prioritization/README.md

   1
   2 To Delete Topics
   3 ------------------
   4 kafka-topics --zookeeper localhost:2181 --delete  --topic prioritize-input-topic
   5 kafka-topics --zookeeper localhost:2181 --delete  --topic prioritize-output-topic
   6 kafka-topics --zookeeper localhost:2181 --delete  --topic test-prioritize-application-PriorityMessage-changelog
   7
   8 Create Topics
   9 --------------
  10
  11 kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-input-topic
  12 kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-output-topic
  13
  14 To List topics
  15 ----------------
  16 kafka-topics --list --bootstrap-server localhost:9092
  17
  18 To publish message
  19 --------------------
  20 kafka-console-producer --broker-list localhost:9092 --topic prioritize-input-topic
  21
  22 To Listen for Output
  23 ----------------------
  24 kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-output-topic --from-beginning
  25
  26 kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-input-topic --from-beginning