@@ -125,7 +125,12 @@ commands:
125125 nifi.cluster.flow.election.max.candidates=
126126 nifi.cluster.flow.election.max.wait.time=1 mins
127127 nifi.cluster.is.node=true
128+ {% if test_scenario ['values' ]['use-zookeeper-manager' ] == 'true' %}
128129 nifi.cluster.leader.election.implementation=CuratorLeaderElectionManager
130+ {% else %}
131+ nifi.cluster.leader.election.implementation=KubernetesLeaderElectionManager
132+ nifi.cluster.leader.election.kubernetes.lease.prefix=${env:STACKLET_NAME}
133+ {% endif %}
129134 nifi.cluster.node.address=${env:NODE_ADDRESS}
130135 nifi.cluster.node.protocol.port=9088
131136 nifi.cluster.protocol.is.secure=true
@@ -200,7 +205,11 @@ commands:
200205 nifi.sensitive.props.key.protected=
201206 nifi.state.management.configuration.file=./conf/state-management.xml
202207 nifi.state.management.embedded.zookeeper.start=false
208+ {% if test_scenario ['values' ]['use-zookeeper-manager' ] == 'true' %}
203209 nifi.state.management.provider.cluster=zk-provider
210+ {% else %}
211+ nifi.state.management.provider.cluster=kubernetes-provider
212+ {% endif %}
204213 nifi.state.management.provider.local=local-provider
205214 nifi.status.repository.questdb.persist.component.days=3
206215 nifi.status.repository.questdb.persist.location=./status_repository
@@ -219,8 +228,10 @@ commands:
219228 nifi.web.max.header.size=16 KB
220229 nifi.web.proxy.context.path=
221230 nifi.web.proxy.host=${env:LISTENER_DEFAULT_ADDRESS}:${env:LISTENER_DEFAULT_PORT_HTTPS},example.com:1234
231+ {% if test_scenario ['values' ]['use-zookeeper-manager' ] == 'true' %}
222232 nifi.zookeeper.connect.string=${env:ZOOKEEPER_HOSTS}
223233 nifi.zookeeper.root.node=${env:ZOOKEEPER_CHROOT}
234+ {% endif %}
224235 security.properties: |
225236 networkaddress.cache.negative.ttl=0
226237 networkaddress.cache.ttl=30
@@ -235,6 +246,7 @@ commands:
235246 <property name =" Partitions" >16</property >
236247 <property name =" Checkpoint Interval" >2 mins</property >
237248 </local-provider >
249+ {% if test_scenario ['values' ]['use-zookeeper-manager' ] == 'true' %}
238250 <cluster-provider >
239251 <id >zk-provider</id >
240252 <class >org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider</class >
@@ -243,6 +255,13 @@ commands:
243255 <property name =" Session Timeout" >10 seconds</property >
244256 <property name =" Access Control" >Open</property >
245257 </cluster-provider >
258+ {% else %}
259+ <cluster-provider >
260+ <id >kubernetes-provider</id >
261+ <class >org.apache.nifi.kubernetes.state.provider.KubernetesConfigMapStateProvider</class >
262+ <property name =" ConfigMap Name Prefix" >${env:STACKLET_NAME}</property >
263+ </cluster-provider >
264+ {% endif %}
246265 </stateManagement >
247266 YAMLEOF
248267 )
0 commit comments