US-560350 Use stream provider if passed, else default to ExternalKafka

pegasystems · Sep 28, 2023 · fe30e0a · fe30e0a
1 parent c294802
commit fe30e0a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tomcat-conf/Catalina/localhost/prweb.xml b/tomcat-conf/Catalina/localhost/prweb.xml
@@ -111,7 +111,11 @@
   {{ end }}
   {{- if .Env.EXTERNAL_STREAM -}}
   <Environment name="prconfig/services/stream/validate" value="true" type="java.lang.String"/>
+  {{- if .ENV.SERVICES_STREAM_PROVIDER -}}
+  <Environment name="prconfig/services/stream/provider" value="{{ .Env.SERVICES_STREAM_PROVIDER }}" type="java.lang.String" />
+  {{ else }}
   <Environment name="prconfig/services/stream/provider" value="ExternalKafka" type="java.lang.String" />
+  {{- end }}
   <Environment name="prconfig/services/stream/broker/url" value="{{ .Env.STREAM_BOOTSTRAP_SERVERS }}" type="java.lang.String" />
   <Environment name="prconfig/services/stream/encryption/security/protocol" value="{{ .Env.STREAM_SECURITY_PROTOCOL }}" type="java.lang.String" />
   <Environment name="prconfig/services/stream/encryption/sasl/mechanism" value="{{ .Env.STREAM_SASL_MECHANISM }}" type="java.lang.String" />