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); }