RHINENG-21216: add new kafka topic for re-evaluation

Author: TenSt

conf/common.env

@@ -11,7 +11,7 @@ KAFKA_READY_ADDRESS=http://kafka:9099/
 # set if you want to bypass kafka SSL verification
 #KAFKA_SSL_SKIP_VERIFY=true
 
-EVAL_TOPIC=patchman.evaluator.upload
+EVAL_TOPIC=patchman.evaluator.user-evaluation
 EVENTS_TOPIC=platform.inventory.events
 NOTIFICATIONS_TOPIC=platform.notifications.ingress
 PAYLOAD_TRACKER_TOPIC=platform.payload-status

conf/evaluator_upload.env

@@ -0,0 +1 @@
+EVAL_TOPIC=patchman.evaluator.upload

conf/local.env

@@ -21,7 +21,7 @@ KAFKA_GROUP=patchman
 KAFKA_SSL_CERT=dev/kafka/secrets/ca.crt
 PAYLOAD_TRACKER_TOPIC=platform.payload-status
 EVENTS_TOPIC=platform.inventory.events
-EVAL_TOPIC=patchman.evaluator.upload
+EVAL_TOPIC=patchman.evaluator.user-evaluation
 TEMPLATE_TOPIC=platform.content-sources.template
 
 RBAC_ADDRESS=http://localhost:9001

deploy/clowdapp.yaml

@@ -476,6 +476,7 @@ objects:
     - {replicas: 3, partitions: 10, topicName: platform.remediation-updates.patch}
     - {replicas: 3, partitions: 10, topicName: platform.notifications.ingress}
     - {replicas: 3, partitions: 10, topicName: platform.content-sources.template}
+    - {replicas: 3, partitions: 4, topicName: patchman.evaluator.user-evaluation}
 
     dependencies:
     - host-inventory
@@ -618,7 +619,7 @@ parameters:
 - {name: REPLICAS_MANAGER, value: '1'}
 - {name: LOG_LEVEL_MANAGER, value: debug}
 - {name: DB_DEBUG_MANAGER, value: 'false'} # Log database queries if enabled
-- {name: EVAL_TOPIC_MANAGER, value: patchman.evaluator.upload}
+- {name: EVAL_TOPIC_MANAGER, value: patchman.evaluator.user-evaluation}
 - {name: CPU_LIMIT_MANAGER, value: 1000m}
 - {name: MEM_LIMIT_MANAGER, value: 2Gi}
 - {name: CPU_REQUEST_MANAGER, value: 500m}

dev/kafka/setup.sh

@@ -7,7 +7,8 @@ sleep 5
 for topic in "platform.inventory.events" "patchman.evaluator.upload" \
              "patchman.evaluator.recalc" "platform.remediation-updates.patch" "platform.notifications.ingress" \
              "platform.payload-status" "test" \
-             "platform.content-sources.template"
+             "platform.content-sources.template" \
+             "patchman.evaluator.user-evaluation"
 do
     until /opt/kafka/bin/kafka-topics.sh --create --if-not-exists --topic $topic \
         --partitions 1 --bootstrap-server kafka:9092 --replication-factor 1; do