diff --git a/src/main/java/fi/hsl/common/pulsar/PulsarApplication.java b/src/main/java/fi/hsl/common/pulsar/PulsarApplication.java index d96b9c53..1c532211 100644 --- a/src/main/java/fi/hsl/common/pulsar/PulsarApplication.java +++ b/src/main/java/fi/hsl/common/pulsar/PulsarApplication.java @@ -199,7 +199,7 @@ protected Consumer createConsumer(@NotNull PulsarClient client, @NotNull if (config.getBoolean("pulsar.consumer.multipleTopics")) { if (config.hasPath("pulsar.consumer.topics")) { - List topics = config.getStringList("pulsar.consumer.topics"); + List topics = Arrays.asList(config.getString("pulsar.consumer.topics").split(",")); log.info("Creating Pulsar consumer for topics: [ {} ]", String.join(", ", topics)); builder = builder.topics(topics); } else { diff --git a/src/main/resources/common.conf b/src/main/resources/common.conf index 5c81acfb..0460cc45 100644 --- a/src/main/resources/common.conf +++ b/src/main/resources/common.conf @@ -12,6 +12,8 @@ pulsar { #Consume multiple topics: multipleTopics=false multipleTopics=${?PULSAR_CONSUMER_ENABLE_MULTIPLE_TOPICS} + topics="" + topics=${?PULSAR_CONSUMER_TOPICS} topicsPattern="" topicsPattern=${?PULSAR_CONSUMER_MULTIPLE_TOPICS_PATTERN} #Options for type: Exclusive, Shared, Failover