Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
437 Commits 5 Branches 0 Tags
0452a06e1106b04832e45ca7e9af5e84b2a90412
Commit Graph

437 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Chris Bono
0452a06e11 [CI] Fix ci not running function ITs (0.2.x) 
- Make integrationTest depend on downloadRabbitConnector
 2023-04-29 22:18:07 -05:00
Chris Bono
dbd1b69e08 Use builder to autoconfigure PulsarClient (#394) 
- Apply PulsarProperties to client builder rather than raw
map of Pulsar properties

- Replace PulsarClientFactoryBean with PulsarClientFactory
 2023-04-28 22:13:10 -05:00
Chris Bono
303573b7a9 Hide observation API from public API on template and listener (#389) 
* Remove observation registry and convention from
  constructors on PulsarTemplate and CPLCF

* Lookup observation registry and convention from
  app context at start time
 2023-04-19 11:54:39 -05:00
Kevin Lu
88dd3f4df6 Add tlsCertificateFilePath/tlsKeyFilePath config (#392) 
Fixes #374
 2023-04-17 22:36:02 -05:00
Chris Bono
86c95f883e Replace refs from spring-projects-experimental to spring-projects 2023-04-10 16:05:33 -05:00
Soby Chacko
0969efe14c Container properties code optimization 2023-03-29 20:16:52 -04:00
Chris Bono
42daa54d33 Follow up on shaded cache modules (#388) 
* Add new module descriptions to README.adoc

* Replace non-shaded Caffeine classes w/
  shaded version in PulsarRuntimeHints.java
 2023-03-29 12:22:56 -05:00
Chris Bono
156b85cd7b Fix publish for shaded caffeine artifact (#387) 
- Don't publish rich Gradle module for
  spring-pulsar-cache-provider-caffeine
 2023-03-28 00:27:36 -05:00
Chris Bono
18eac19012 Add cache provider / shade caffeine (#386) 2023-03-27 19:13:05 -05:00
Chris Bono
634f60df96 [CI] Update release workflow for 0.2.0 
- Add 0.2.0 to hardcoded list of pre-releases
- Fix branch creation for full GA step
 2023-03-24 11:15:11 -05:00
Chris Bono
c2656f6a89 [Release 0.2.0] Next development version 2023-03-23 22:18:25 -05:00
Chris Bono
4aac315569 [Release 0.2.0] Update version (#383) 
Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
 2023-03-23 20:48:31 -05:00
Soby Chacko
ea8aea76f8 Pulsar topic types in Container Properties 
Pulsar Java client expects topics to be provided as a Set.
In PulsarContainerProperties, we were using an array type.
In order to make it consistent with the Pulsar Java client, we are
migrating this type in PulsarContainerProperties to Set<String>.
 2023-03-23 16:11:21 -04:00
Chris Bono
45da73d817 Add LinkedHashMap to AOT hints (#382) 2023-03-23 14:00:25 -05:00
Chris Bono
f282a9a6d9 Dependency hygiene required by Spring Boot (#376) 2023-03-23 12:54:20 -05:00
Soby Chacko
29cfd301c6 Better container properties sync 
* If consumer properties are directly overridden, we need to
   sync that with container properties. This commit tries to
   centralize this synching.
 2023-03-23 13:51:22 -04:00
Chris Bono
71241a212b Update Spring Boot 3.0.5 (#381) 2023-03-23 12:28:39 -05:00
Chris Bono
488c5d2e64 Add AOT support for Pulsar binder. (#379) 
- Adds native hints to allow the
  binder to run in a GraalVM native
  image.
 2023-03-22 21:59:02 -05:00
Soby Chacko
8300f1a4be Subscription Type Propagation in the Binder 2023-03-22 13:17:18 -04:00
Chris Bono
19cc0ab070 Simplify defaults type mappings (#377) 
* Remove redundant SchemaInfo.messageType as
  the key of the type mappings tells us that
  info
 2023-03-21 20:19:01 -05:00
Soby Chacko
0f84199138 Formatting the binder sample app 2023-03-21 19:18:16 -04:00
Soby Chacko
2609b08869 Fix checkstyle on the Binder sample app 2023-03-21 18:53:15 -04:00
Soby Chacko
d4e816e52a Binder sample app update with DLT 2023-03-21 18:34:10 -04:00
Chris Bono
b1024a9991 Update to Spring Boot 3.0.4 2023-03-15 10:46:12 -04:00
Chris Bono
6fedfa9c0c Allow schema mapping via config props (#371) 
* Allow schema mapping via config props

* Adds a `schema-info` property to the
  `spring.pulsar.defaults.type-mappings` which
  allows users to configure a default
  schema by message type via config props

* Add docs for schema mapping via config props

* Fix unit test
 2023-03-14 17:16:53 -04:00
Chris Bono
fd41a8f836 [CI] Add aggregate jacoco report (#370) 2023-03-11 21:51:17 -06:00
Chris Bono
1a2dcb8610 Remove heading from pulsar-header.adoc (#369) 
* Remove heading from pulsar-header.adoc

- Also include jacoco upload to ci-pr.yml

* Remove heading from pulsar-header.adoc

- Also include jacoco upload to ci-pr.yml
 2023-03-08 11:05:14 -05:00
Chris Bono
25a2ee005d Add header mapper docs to binder docs (#368) 
See #366
 2023-03-07 10:22:12 -06:00
Chris Bono
a0c9dabbe5 Add SCSt binder header mapper (#367) 
- Add binder specific header mapper
- Add IT tests for binder header mapping

See #366
 2023-03-06 12:19:19 -06:00
Chris Bono
7ee8ee12b1 Add filter/encode ability to header mappers (#366) 
- Add simple 'ToString' mapper
- Add 'json' mapper for complex types
- Delete 'default' mapper
- Use 'json' mapper as default mapper
- Inbound/outbound filter rules

See #361
 2023-03-05 12:26:56 -06:00
Chris Bono
a532071695 Add bindings props to generated docs 
Fixes #362
 2023-02-27 10:43:07 -05:00
Soby Chacko
82f4fb512c PulsarReader docs 2023-02-24 15:09:57 -05:00
Chris Bono
f3890db3a2 [Docs] Move topic resolution out of appendix (#363) 2023-02-24 12:20:35 -06:00
Chris Bono
0458f01b3e Binder preserves headers on send/receive (#359) 
- Refactor the existing PulsarMessageHeaderMapper to include to/from support.
- Use the new API in the binder send/receive
- Add tests for header mapper

See #358
 2023-02-24 09:31:36 -06:00
Chris Bono
e989f4e03b Add pause in functions IT after context close 
- The PulsarFunctionAdministrationIntegrationTests needs a pause
  after context close to give the stop policy time to run before
  verifying function status
 2023-02-24 09:03:06 -06:00
Chris Bono
ee1aaf7514 Make spring-cloud-stream version dynamic in docs 2023-02-24 09:30:13 -05:00
Soby Chacko
78dec77bb8 Initial infra for Pulsar binder/binding properties docs 2023-02-23 20:38:19 -05:00
Soby Chacko
a8ca3932f2 Pulsar topic provisioner binder docs 2023-02-23 18:38:50 -05:00
Soby Chacko
0e4fe50651 Pulsar binder/binding properties docs 2023-02-23 17:48:12 -05:00
Soby Chacko
d04e3054b9 Binder docs polishing 2023-02-23 16:31:28 -05:00
Soby Chacko
0b3521a536 Binder message conversion docs 2023-02-23 15:31:01 -05:00
Soby Chacko
6a1dfdeda8 Initial Pulsar Binder Docs 2023-02-23 12:42:43 -05:00
Soby Chacko
44d13742ec ReaderBuilderCustomizer through PulsarReader 2023-02-22 19:51:30 -05:00
Soby Chacko
e310f18f17 Refactor ReactivePulsarListenerAnnotationBeanPostProcessor 
- Extend ReactivePulsarListenerAnnotationBeanPostProcessor
   from AbstractPulsarAnnotationsBeanPostProcessor.
 2023-02-22 17:50:56 -05:00
Soby Chacko
6cf83a4296 Adding Consumer Customizations through PulsarListener 2023-02-22 16:29:14 -05:00
Chris Bono
dad0961eac Fix flaky PulsarFunctionAdministrationIntegrationTests 
Pause after context close to give stop policies time to execute
 2023-02-22 12:45:27 -06:00
Soby Chacko
fa7a2fa818 Consolidate message container hierarchy 
Initial refactoring for extracting a common abstract class for various containers.
 2023-02-22 12:36:49 -05:00
Soby Chacko
abe3786615 Message Listener/Reader consolidation 
- Consolidate and refactor the hierarchy between Listener
   and Reader adpaters/converters
 - Remove unncessary batch message converters
 2023-02-21 17:05:00 -05:00
Soby Chacko
9189654ab0 Reader classes naming cleanup 2023-02-21 15:22:17 -05:00
Soby Chacko
05ff873271 Remove Listener name from the Reader core classes 2023-02-21 15:09:04 -05:00