Skip to content

Commit ae0836a

Browse files
Heng CuiHeng Cui
authored andcommitted
update deployment test accordingly
1 parent a5ad1a0 commit ae0836a

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

candyfloss/src/test/java/com/swisscom/daisy/cosmos/candyfloss/AbstractDeploymentTest.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,9 @@ protected TopologyTestDriver setupTopology(String applicationConfigFileName)
4949
throws IOException, InvalidConfigurations, InvalidMatchConfiguration {
5050
Config config = ConfigFactory.load(applicationConfigFileName);
5151
appConf = JsonKStreamApplicationConfig.fromConfig(config);
52-
CandyflossKStreamsApplication app = new CandyflossKStreamsApplication(appConf);
52+
// in deployment unittest, use inputTopicName regardless of pattern subscription configuration.
53+
CandyflossKStreamsApplication app =
54+
new CandyflossKStreamsApplication(appConf.withoutInputTopicPattern());
5355
final Topology topology = app.buildTopology();
5456
var kafkaConfig = appConf.getKafkaProperties();
5557
kafkaConfig.setProperty("application.id", UUID.randomUUID().toString());

0 commit comments

Comments
 (0)