This updates several depenedencies used by Antora and locks the
version of `fast-xml-parser` to `4.5.2` to get around issue with
Antora using `latest` version of that lib.
This allows pulsar metadata headers, which are excluded on the
outbound messages by default, to be included in the outbound
message headers.
Resolves#1037
The docs has code examples using a consumer property named
`ackTimeout`. However, the actual property name is
`ackTimeoutMillis`. This updates those references.
Resolves#1010
This commit updates the supported version of the pulsar-client-reactive
library in the compatibiity matrix doc from `0.6.0` to the actual
supported version `0.5.x`.
This commit makes sure that all usages of String toLowerCase and
toUpperCase specify a Locale (default of Locale.ROOT).
Also, a checkstyle rule is added to prevent usage of the no-arg variant
of String toLowerCase and toUpperCase.
The purpose of `ConcurrentPulsarListenerContainerFactoryCustomizer` was
to customize the Spring Boot auto-configured message container
factories. However, Spring Boot has introduced a generic message
container factory customizer `PulsarContainerFactoryCustomizer` that
removes the need for this customizer.
This commit deprecates the Spring for Apache Pulsar customizer in favor
of the Spring Boot provided generic container factory customizer.
This introduces a common interface for all message listener containers.
Prior to this commit, the reader and listener containers had no common
abstraction. This is needed to introduce a generic container factory
customizer in Spring Boot.
Previously, when a listener container failed to start, it
would only log the exception. This commit introduces
`StartupFailurePolicy` that allows listener containers to CONTINUE,
STOP, RETRY when an error is encountered on startup.
See #445
See #816
This commit moves the default subscription name from the
`@PulsarListener` and `@ReactivePulsarListener` annotation to the
corresponding container factory (props) which allows the
`spring.pulsar.consumer.subscription.name` config prop to be respected.
See https://github.com/spring-projects/spring-boot/issues/42053
This commit moves the default subscription type from the
`@PulsarListener` and `@ReactivePulsarListener` annotation to the
associated container factory (props) which allows the Spring Boot
`spring.pulsar.consumer.subscription-type` config prop to be respected.
See https://github.com/spring-projects/spring-boot/issues/42053
Prior to this commit, the version number used in the Pulsar docs link
was hardcoded to `3.2.x`. Now the version number is derived from the
Pulsar client lib version specified in libs.version.toml.
* Update to Pulsar 3.3.1
* Handles deprecation to PulsarClient.getPartitionsForTopic(String)
* Adds support to PulsarClientProxy for newly added
PulsarClient.getPartitionsForTopic(String, boolean)
* Add deprecation note to "What's New" doc
Resolves#767
This commit adds support for a user-provided Jackson ObjectMapper to be
used when deserializing JSON header values.
See #723
Co-authored-by: Jihoon Kim <pigberger70@gmail.com>
This commit adds support for a user-provided Jackson ObjectMapper to be
used when de/serializing JSON messages.
Additionally, adds Gradle test fixtures to the spring-pulsar module and
deprecates the UserRecord and UserPojo in spring-pulsar-test in favor
of their equivalent in the test fixture.
See #723
Updates the reactive-message-consumption.adoc to clarify the difference
between the factory methods on `MessageResult` and `MessageUtils`.
Resolves#666
This commit makes the spring-pulsar-test module available externally.
Additionally:
* Add missing package-info.java in several packages
* Update doc on how to use PulsarTestContainerSupport
- update javadocs a bit
- reorder some constructors based on specificity
- add null check to "withSchema"
- rename the test to end w/ "Tests" (plural) for consistency
- simplified doc examples a bit w/ String message type
- drop the exact match API
- rename the conditions factory methods
