86abb49ab2
Enable configurable concurrency for pulsar ( #3330 )
...
Signed-off-by: yaron2 <schneider.yaron@live.com>
2024-02-02 10:29:31 -08:00
9095b0e7e7
Switch to Go 1.21, Updates linter, updates workflows, adds sarama 1.42.1 ( #3251 )
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-11-28 18:13:09 -08:00
76b8480ff9
Add consumer proto schema validation for pulsar ( #3014 )
...
Signed-off-by: yaron2 <schneider.yaron@live.com>
Signed-off-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
2023-07-25 18:12:47 +00:00
a1bf2ea00a
Add Apache Pulsar e2e encryption ( #2812 )
...
Signed-off-by: yaron2 <schneider.yaron@live.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2023-04-28 18:19:15 +00:00
2b89d78a2d
Refactor Metadata Parsing of all PubSub Components ( #2759 )
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-04-09 18:21:56 +00:00
1dc20e6c69
Add schema support to apache pulsar ( #2475 )
...
* add schema support to apache pulsar
Signed-off-by: yaron2 <schneider.yaron@live.com>
* linter and avro support
Signed-off-by: yaron2 <schneider.yaron@live.com>
* fix nit
Signed-off-by: yaron2 <schneider.yaron@live.com>
* fix go.mod
Signed-off-by: yaron2 <schneider.yaron@live.com>
* update cert test go.mod
Signed-off-by: yaron2 <schneider.yaron@live.com>
* update cert test metadata to latest
Signed-off-by: yaron2 <schneider.yaron@live.com>
* schema identifier refactor to handle edge case
Signed-off-by: yaron2 <schneider.yaron@live.com>
* fix shadow
Signed-off-by: yaron2 <schneider.yaron@live.com>
Signed-off-by: yaron2 <schneider.yaron@live.com>
2023-01-26 13:10:58 -08:00
a51de3bb09
Add metadata property to configure Batching in Pulsar ( #1707 )
...
* Add metadata property to configure BatchingMaxSize&batchingMaxMessages in Pulsar
Signed-off-by: saberwang <saberwang@hotmail.com>
* sort field
Signed-off-by: saberwang <saberwang@hotmail.com>
* [pubsub]fix unit test bug
Signed-off-by: saberwang <saberwang@hotmail.com>
* remove unrelated changes
Signed-off-by: saberwang <saberwang@hotmail.com>
* Delete hard coded Metadata
Signed-off-by: saberwang <saberwang@hotmail.com>
* remove .history
Signed-off-by: saberwang <saberwang@hotmail.com>
* restore .gitignore
Signed-off-by: saberwang <saberwang@hotmail.com>
* Hard coding default values and adding 'BatchingMaxPublishDelay' metadata
Signed-off-by: saberwang <saberwang@hotmail.com>
* fix code format
Signed-off-by: saberwang <saberwang@hotmail.com>
* formatting code
Signed-off-by: saberwang <saberwang@hotmail.com>
Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-05-06 17:59:27 -07:00
00c99a4027
feature/pulsar: add producer option disableBatching
...
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-01-07 12:45:14 +08:00
c7adb917f3
update license to Apache v2.0 ( #1406 )
2022-01-04 19:53:31 -08:00
4bf0dcbfcf
Fix the Route of subscription API does not work on pubsub.pulsar ( #1283 )
...
* feat(pulsar): add tenant and namesapce. fix topic parsing.
* add test
* fix review add topic format unit test
* fix review: add persistent to metadata, fix nits
* fix lint
Co-authored-by: Long Dai <long.dai@intel.com>
Co-authored-by: Mukundan Sundararajan <musundar@microsoft.com>
Co-authored-by: Simon Leet <31784195+CodeMonkeyLeet@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2021-11-22 18:57:53 -08:00
988fed05ab
ci: standard linter config ( #1102 )
...
* ci: standard linter config
Signed-off-by: Long <long.dai@intel.com>
* Update utils.go
* fix pulsar issue
Signed-off-by: Long <long.dai@intel.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-09-21 15:21:59 -07:00
c425f1319a
feature/pubsub: add delay queue params for pulsar ( #1112 )
...
* feature/pubsub: add delay queue params for pulsar
* feature/pubsub: add delay queue params for pulsar
* feature/pubsub: add delay queue params for pulsar
* feature/pubsub: add delay queue params for pulsar
* feature/pubsub: add delay queue params for pulsar
Co-authored-by: Simon Leet <31784195+CodeMonkeyLeet@users.noreply.github.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-09-17 11:41:47 -07:00
f647d9eedb
Upgrade golang lint to 1.31 ( #490 )
...
Upgrade golang lint to 1.31.0
https://github.com/dapr/components-contrib/issues/439
2020-10-12 12:54:15 -07:00
b54585c4f0
Apache Pulsar - pubsub component ( #346 )
...
* created pulsar component
* fixed multi topic issue
* moved metadata struct
* finished writing metadata tests
* fixed linter issues
* modifies consumer type to failover
* uncapitalized errors
* changed subscriptionName to consumerID
* acknowledge message only if there's no error returned from handler
Co-authored-by: john verdonck <John@johns-MacBook-Pro.local>
2020-05-22 10:04:07 -07:00
Yaron Schneider
Bernd Verst
saber-wang
1046102779
Dmitry Shmulevich
Taction
Long Dai
halspang
John