Fix payload type in Reactive tombstone doc (#678)

Also clarify that `org.apache.pulsar.client.api.Messages<T>` are not
supported in `@ReactivePulsarListener`.

Fixes #667
This commit is contained in:
Chris Bono
2024-05-17 16:04:34 -05:00
committed by GitHub
parent f5361f0916
commit d672e2d405
2 changed files with 3 additions and 1 deletions

View File

@@ -112,6 +112,8 @@ Flux<MessageResult<Void>> listen2(Flux<org.springframework.messaging.Message<Foo
NOTE: The listener method returns a `Flux<MessageResult<Void>>` where each element represents a processed message and holds the message id, value and whether it was acknowledged.
The Spring `MessageUtils` has a set of static factory methods that can be used to create the appropriate `MessageResult` instance from a Spring message.
NOTE: There is no support for using `org.apache.pulsar.client.api.Messages<T>` in a `@ReactivePulsarListener`
=== Configuration - Application Properties
The listener relies on the `ReactivePulsarConsumerFactory` to create and manage the underlying Pulsar consumer that it uses to consume messages.
Spring Boot provides this consumer factory which you can further configure by specifying the {spring-boot-pulsar-config-props}[`spring.pulsar.consumer.*`] application properties.

View File

@@ -36,7 +36,7 @@ For `@ReactivePularListener`, the `null` payload is passed into the listener met
| `Flux<org.apache.pulsar.client.api.Message<T>>`
| non-null flux whose entries are non-null Pulsar messages whose `getValue()` returns `null`
| `Flux<org.apache.pulsar.client.api.Messages<T>>`
| `Flux<org.springframework.messaging.Message<T>>`
| non-null flux whose entries are non-null Spring messages whose `getPayload()` returns `PulsarNull`
|===