Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
444 Commits 5 Branches 0 Tags
0.2.x
Commit Graph

59 Commits

Author SHA1 Message Date
Chris Bono
71241a212b Update Spring Boot 3.0.5 (#381) 2023-03-23 12:28:39 -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
Soby Chacko
82f4fb512c PulsarReader docs 2023-02-24 15:09:57 -05:00
Soby Chacko
0621c540d6 PulsarReader Infrastructure 
- Introducing PulsarReader annotation
 - Annotation bean post processor for PulsarReader
 - PulsarReader container and registry
 - PulsarReader endpoint and registry
 - PulsarReaderConfigurer
 - PulsarReader based listener adapter
 - PulsarReader annotation driven Boot auto configuration

Resolves https://github.com/spring-projects-experimental/spring-pulsar/issues/353
 2023-02-17 14:39:13 -05:00
Chris Bono
64159ff350 Update Pulsar to 2.11.0 (#337) 
* User template vars for links to pulsar docs site
* Update all code references to `2.11.0`
 2023-02-14 14:52:09 -06:00
Christophe Bornet
9fb8879491 Bump the Pulsar reactive client to 0.2.0 (#307) 2023-02-07 09:19:41 -06:00
Chris Bono
f108bc202b Update copyright 2023 on all source files (#318) 
* Add ability to update all copyrights

* Update all source copyrights to 2023

* Disabling problematic pause/resume test
 2023-02-06 15:54:34 -06:00
Chris Bono
59a4d94964 Update Pulsar 2.10.3 (#315) 2023-02-06 14:04:59 -06:00
Chris Bono
dd09c98c01 Update Spring Boot 3.0.2 (#314) 
Also update:
* testcontainersVersion = `1.17.6`
* springCloudStreamVersion = `4.0.1`
 2023-02-06 09:05:52 -06:00
Chris Bono
6fdd6c743c Update SCSt binder sample 
* Use 2 different types of schema
now that the setSchema is thread-safe.
 2023-01-30 10:39:18 -05:00
Chris Bono
7294580bfa Add topic resolver (#293) 
* Add topic resolver

- Topic resolver with configurable
message type to topic name mappings

See #269

* Sample app uses topic and schema resolver

* Add topic resolver docs
 2023-01-30 10:38:19 -05:00
Chris Bono
ed2a67b0c4 Remove setSchema API from templates 
For both PulsarTemplate and ReactivePulsarTemplate:
* remove setSchema()
* add schema param in simple API
* add schema param in fluent API

Update all tests and samples accordingly

See #268
 2023-01-25 12:54:12 -05:00
Chris Bono
f4d10811ca Binder sample app uses complex types 2023-01-23 12:55:09 -05:00
Soby Chacko
ea1597a0a1 Pulsar binder subscription name improvements 
Provide a default subscription name that is anonymous each time the app starts.
This can be overridden to a fixed subscription name by providing it as a property.
 2023-01-20 16:22:12 -05:00
Soby Chacko
ada87dbeee Pulsar binder schema related changes (#282) 
* Pulsar binder schema related changes

* PR review
 2023-01-20 14:14:53 -05:00
Soby Chacko
1969c8a488 Spring Cloud Stream Pulsar Binder (#276) 
* Spring Cloud Stream Pulsar Binder

Basic consumer and producer bindings.
Sample app (end to end)

* PR review
 2023-01-19 13:07:07 -05:00
Chris Bono
7789f89ab0 Add robust IT for PulsarFunctionAdministration (#272) 2023-01-15 23:33:18 -06:00
Chris Bono
66beedef86 Add stop policy for Pulsar Functions (#271) 2023-01-13 16:04:52 -06:00
Chris Bono
195b2fb77b Add sample app for Pulsar Functions 
See #135 #136
 2023-01-11 14:12:55 -05:00
Chris Bono
4ca7b1266a [Build] Skip other sonatype tasks for samples 2022-12-14 15:23:04 -06:00
Chris Bono
e36f98d1aa [Build] Don't publish samples to Sonatype 
- increase Sonatype state transition retries
 2022-12-14 14:12:38 -06:00
Chris Bono
0336228e99 Add reactive docs (#250) 
Fixes #201
 2022-12-12 00:32:14 -06:00
Chris Bono
2a7a0b9e0e Update to Spring Boot 3.0.0 (#241) 
- Also update Micrometer docs gen to M7

Fixes #177
 2022-11-26 19:45:05 -06:00
Christophe Bornet
1055637ff2 Update with new MessageResult::acknowledge(Message) function (#233) 2022-11-21 20:05:56 -06:00
Chris Bono
2024206a28 Update reactive sample with @ReactivePulsarListener (#218) 2022-11-18 16:04:52 -06:00
Chris Bono
a8d65ec168 Split reactive into its own module 
Remove redundant dep
 2022-11-17 20:47:44 -05:00
Christophe Bornet
422aa8e5c9 Use type safe structures to configure the producer 
Changes following review

Changes following review
 2022-11-10 21:15:11 -06:00
Christophe Bornet
a5ddf77ced Add ReactivePulsarMessageListenerContainer (#198) 2022-11-10 12:52:53 -06:00
Christophe Bornet
82815d9dc5 Rename ReactivePulsarSenderTemplate to ReactivePulsarTemplate 2022-11-10 12:48:54 -06:00
Chris Bono
5dd3a4a181 Update to Spring Boot 3.0.0-RC1 2022-11-07 18:25:03 -06:00
Chris Bono
1fcc2fbb25 Add spring-boot-starter as api dep. in starters 2022-11-07 14:14:08 -06:00
Chris Bono
600ade21aa Add spring-boot-starter to reactive-sample-app 2022-11-07 10:46:32 -06:00
Chris Bono
58fd8d026b Add Reactive sample app 2022-11-07 10:41:55 -06:00
Chris Bono
4953c2234c Split sample apps into multi-modules 
Cherry pick 87e349066b
 2022-11-07 10:40:57 -06:00
Chris Bono
87e349066b Split sample apps into multi-modules (#186) 2022-10-29 14:39:52 -05:00
Chris Bono
fed6a0c40f Add package-info.java setting all things @NonNull 
- Adjusted producer pieces to get rid of warnings
- Other areas to be updated as we encounter the warnings
 2022-10-24 16:26:52 -04:00
Chris Bono
afe4fb6707 Set tracing probability to 100% on sample apps 2022-10-12 19:24:10 -05:00
Chris Bono
90a39b8f84 Add Micrometer Tracing to sample apps (#160) 
Also documents how to configure Micrometer Observations.

See #147
 2022-10-12 17:09:40 -05:00
Chris Bono
cd8adafa07 Add jvm args with add-opens (#145) 
- when running sample apps
- when running tests

Closes #143
 2022-09-27 20:17:27 -05:00
Chris Bono
4d3fd12202 [Release 0.1.0-M1] Switch back to SB/SF snapshots 2022-09-23 15:08:40 -04:00
Chris Bono
5afb4d719c Use enum for PulsarListener subscriptionType (#122) 
* Use enum for PulsarListener subscriptionType

* Fix checkstyle
 2022-09-16 17:01:21 -04:00
Chris Bono
c59db85990 Use SB/SF milestone libs for M1 release (#109) 
* Use SB/SF milestone libs for M1 release

- Made the following TEMPORARY changes to appease downgrading to SB/SF milestones:
  - Removed `AsynTaskExecutor.submitCompletable` (only in SF snaphot)
  - Revert b188436ab5 (auto-generated auto-config imports file only in SB snapshot)
- Added SpringBootTest sanity test to catch when auto-config is not in place.

* Checkstyle fix on newly added test
 2022-09-13 13:01:13 -04:00
Chris Bono
d4dfcee77c Add custom tasks to run samples (#105) 
- bootRunApp1
- bootRunApp2
 2022-09-11 12:36:33 -05:00
Chris Bono
fbc4773dbd Update SB plugin to 3.0.0-SNAPSHOT in sample apps (#103) 
Fixes #92
 2022-09-11 12:28:59 -05:00
Chris Bono
c1d155e507 Add fluent API to PulsarTemplate 
Fixes #68
 2022-08-29 14:42:18 -05:00
Alexander Preuß
67cb57c800 Add auto-configuration for PulsarAdministration (#72) 
* Auto-configures a `PulsarAdministration`
* Reconciles some properties for admin and regular clients
* Adds docs for config props (see #50)

Resolves #41
 2022-08-29 13:30:16 -05:00
Soby Chacko
a28b73e93b Fixing sample application 2022-08-23 14:30:01 -04:00