ms/blueprintsprocessor/functions/message-prioritizaion/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 prioritize-expired-topic
   7 kafka-topics --zookeeper localhost:2181 --delete  --topic test-prioritize-application-PriorityMessage-changelog
   8
   9 Create Topics
  10 --------------
  11
  12 kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-input-topic
  13 kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-output-topic
  14 kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-expired-topic
  15
  16 To List topics
  17 ----------------
  18 kafka-topics --list --bootstrap-server localhost:9092
  19
  20 To publish message
  21 --------------------
  22 kafka-console-producer --broker-list localhost:9092 --topic prioritize-input-topic
  23
  24 To Listen for Output
  25 ----------------------
  26 kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-output-topic --from-beginning
  27
  28 kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-input-topic --from-beginning
  29
  30 kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-expired-topic --from-beginning
  31