From 015346d095dadbba937f961c6eb75bd2cbbd1446 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Sat, 11 Nov 2023 23:44:22 -0600 Subject: [PATCH] Update sample reader app to remove subscription name from @PulsarReader --- .../src/main/java/reader/app/SpringPulsarReaderBootApp.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/spring-pulsar-sample-apps/sample-pulsar-reader/src/main/java/reader/app/SpringPulsarReaderBootApp.java b/spring-pulsar-sample-apps/sample-pulsar-reader/src/main/java/reader/app/SpringPulsarReaderBootApp.java index de9f812a..478b1cf0 100644 --- a/spring-pulsar-sample-apps/sample-pulsar-reader/src/main/java/reader/app/SpringPulsarReaderBootApp.java +++ b/spring-pulsar-sample-apps/sample-pulsar-reader/src/main/java/reader/app/SpringPulsarReaderBootApp.java @@ -50,8 +50,7 @@ public class SpringPulsarReaderBootApp { }; } - @PulsarReader(id = "my-id", subscriptionName = "pulsar-reader-demo-subscription", - topics = "pulsar-reader-demo-topic", startMessageId = "earliest") + @PulsarReader(id = "my-id", topics = "pulsar-reader-demo-topic", startMessageId = "earliest") void read(String message) { logger.info(message); }