Adding docs for consumer properties on PulsarListener

This commit is contained in:
Soby Chacko
2022-08-12 18:22:17 -04:00
parent 84a57491d2
commit 33648dcda2

View File

@@ -180,6 +180,22 @@ public void listen4(Messages<Foo> messages) {
----
====
When using `PulsarListener`, you can provide Pulsar consumer properties directly on the annotation itself.
This is convenient, if you do not want to use the Boot configuration properties mentioned above or have multiple `PulsarListener` methods.
Here is an example of using Pulsar consumer properties directly on `PulsarListener`.
====
[source, java]
----
@PulsarListener(properties = { "subscriptionName=subscription-1", "topicNames=foo-1", "receiverQueueSize=5000" })
void listen(String message) {
}
----
====
Note that the properties used are direct Pulsar consumer properties.
[[pulsar-message-listener-container]]
=== Pulsar Message Listener Container