diff options
author | 2020-01-02 11:59:29 -0500 | |
---|---|---|
committer | 2020-01-02 11:59:29 -0500 | |
commit | 4f4e2de08d3c6259da2497950a96d549d3e82f8a (patch) | |
tree | 4c5a8e7a97d96e9de73ecb7ed1b53597ee0ebdd5 /ms/blueprintsprocessor/functions/message-prioritizaion/README.md | |
parent | ba75d2fad2b0111a510f4ee4cc87e658fb32ac4b (diff) |
Message Prioritization message group lock.
Implementation to avoid concurrent procession of message group while prioritization.
Sample message prioritization Kafka listener properties.
Issue-ID: CCSDK-2011
Signed-off-by: Brinda Santh <bs2796@att.com>
Change-Id: Ifbf39985b03c662b6ccf7740be711cfeb7bfbebb
Diffstat (limited to 'ms/blueprintsprocessor/functions/message-prioritizaion/README.md')
-rw-r--r-- | ms/blueprintsprocessor/functions/message-prioritizaion/README.md | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/ms/blueprintsprocessor/functions/message-prioritizaion/README.md b/ms/blueprintsprocessor/functions/message-prioritizaion/README.md new file mode 100644 index 000000000..482bbc2cc --- /dev/null +++ b/ms/blueprintsprocessor/functions/message-prioritizaion/README.md @@ -0,0 +1,31 @@ + +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 prioritize-expired-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 +kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic prioritize-expired-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 + +kafka-console-consumer --bootstrap-server localhost:9092 --topic prioritize-expired-topic --from-beginning + |