Toggler av publisering av produksjonsstyringhendelser (#222)

Author: espenjv

deploy/dev-gcp.yml

@@ -255,6 +255,8 @@ spec:
     # Feature-flag
     - name: KODEVERK_SOM_STRING_TOPICS
       value: "true"
+    - name: PUBLISER_PRODUKSJONSSTYRING_HENDELSE
+      value: "false"
 
     # Konfigurasjoner
     - name: FLYWAY_REPAIR_ON_FAIL

deploy/prod-gcp.yml

@@ -243,6 +243,8 @@ spec:
         # Feature-flag
     - name: KODEVERK_SOM_STRING_TOPICS
       value: "true"
+    - name: PUBLISER_PRODUKSJONSSTYRING_HENDELSE
+      value: "false"
 
     # Konfigurasjoner
     - name: FLYWAY_REPAIR_ON_FAIL

domenetjenester/behandling/src/main/java/no/nav/ung/sak/behandling/hendelse/produksjonsstyring/PubliserProduksjonsstyringHendelseProducer.java

@@ -15,6 +15,8 @@
 @ApplicationScoped
 public class PubliserProduksjonsstyringHendelseProducer extends KafkaProducer {
 
+    private boolean skalPublisereHendelse;
+
     public PubliserProduksjonsstyringHendelseProducer() {
         // for CDI proxy
     }
@@ -29,7 +31,9 @@ public PubliserProduksjonsstyringHendelseProducer(@KonfigVerdi("kafka.produksjon
                                                       @KonfigVerdi(value = "NAIS_NAMESPACE", defaultVerdi = "k9saksbehandling") String appNamespace,
                                                       @KonfigVerdi(value = "NAIS_APP_NAME", defaultVerdi = "ung-sak") String appName,
                                                       @KonfigVerdi("systembruker.username") String username,
-                                                      @KonfigVerdi("systembruker.password") String password) {
+                                                      @KonfigVerdi("systembruker.password") String password,
+                                                      @KonfigVerdi(value = "PUBLISER_PRODUKSJONSSTYRING_HENDELSE", defaultVerdi = "false") boolean skalPublisereHendelse) {
+        this.skalPublisereHendelse = skalPublisereHendelse;
         Properties properties = new Properties();
 
         properties.put(CommonClientConfigs.CLIENT_ID_CONFIG, "KP-" + topic);
@@ -57,6 +61,9 @@ public PubliserProduksjonsstyringHendelseProducer(@KonfigVerdi("kafka.produksjon
     }
 
     public void sendJsonMedNøkkel(String nøkkel, String json) {
+        if (!skalPublisereHendelse) {
+            return;
+        }
         runProducerWithSingleJson(new ProducerRecord<>(topic, nøkkel, json));
     }
 }