diff --git a/tests/ctst/steps/pra.ts b/tests/ctst/steps/pra.ts index 1bc59563a6..9a71c0a388 100644 --- a/tests/ctst/steps/pra.ts +++ b/tests/ctst/steps/pra.ts @@ -49,14 +49,16 @@ interface DrState { } async function installPRA(world: Zenko, sinkS3Endpoint = 'http://s3.zenko.local') { + const kafkaExternalIpOption = !!world.parameters.KafkaExternalIps ? + { kafkaExternalIps: world.parameters.KafkaExternalIps } : + { kafkaExternalIpsDiscovery: true }; + return world.zenkoDrCtl?.install({ sourceZenkoDrInstance: 'end2end-source', sinkZenkoDrInstance: 'end2end-pra-sink', kafkaPersistenceSize: '1Gi', kafkaPersistenceStorageClassName: '-', kafkaPersistenceSelector: 'app=kafka-dr-sink', - kafkaExternalIps: world.parameters.KafkaExternalIps, - kafkaExternalIpsDiscovery: !world.parameters.KafkaExternalIps, locations: 'e2e-cold', // comma-separated list s3Bucket: 'dump-db', sinkZenkoInstance: 'end2end-pra', @@ -65,6 +67,7 @@ async function installPRA(world: Zenko, sinkS3Endpoint = 'http://s3.zenko.local' sourceZenkoNamespace: 'default', sourceS3Endpoint: 'http://s3.zenko.local', sinkS3Endpoint, + ...kafkaExternalIpOption, }); }