Update sample reader app to remove subscription name from @PulsarReader

2023-11-11 23:44:22 -06:00
parent baecaaaa9e
commit 015346d095
1 changed files with 1 additions and 2 deletions
--- 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);
 	}