b2d8e6013b
Add bulkSubscribe request params to SubscribeRequest ( #2405 )
...
* Add bulkSubscribe configuration params
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Replace dapr/dapr package to run cert tests
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Change bulkSubscribe param types
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update latest dapr/dapr fork
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update correct dapr/dapr version
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* change BulkSubscribeRequest to Config
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update dapr/dapr version for cert
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update with latest dapr fork
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2023-01-10 09:30:25 -08:00
bcd101abad
Keys rename ( #2135 )
...
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-28 09:52:59 -07:00
8500da577c
Conf test for Bulk Subscribe and Kafka fixes ( #2113 )
...
* Conf test for Bulk Sub and Kafka Fixes
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Fix linting
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Incorporating comments
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-23 09:54:21 -07:00
217505fd16
Move common costants to common utils
...
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 22:22:54 +05:30
d602e0ab0c
Move constants to utils
...
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 22:07:38 +05:30
81898d5ee5
Config Per Topic and using maxAwaitDuration
...
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 20:04:32 +05:30
f5542c70b9
Incorporate review comments and remove index based entryID
...
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-15 16:02:30 +05:30
059461c6f4
Add kafka changes for bulk subscribe
...
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-13 01:01:05 +05:30
ca9fbf690e
Fixed Kafka PubSub to allow multiple handlers for different topics ( #1755 )
...
* Fixed Kafka PubSub to allow multiple handlers for different topics
With this, tests from #1743 are passing
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Removed read lock (for now)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Updated as requested by @skyao
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Use interface type everywhere
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Fixed panic
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-06-01 15:31:11 -07:00
8b5554dc71
Refactory kafka binding to reuse the kafka common code extracting from kafka pubsub component ( #1696 )
...
* refactory kafka pubsub code to extract common kafka code for reuse
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* fix lint;add unit test for subscribeAdapter
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* move topics filed from internal kafak struct to pubsub kafka struct, since in input binding the topics will confiured in metadata
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* reuse internal kafka code for bindings
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* add redis standalone_test back which is delete by mistaken
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* small code improvement to trigger test
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* add license headers
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* try to set disbaleTls to true to verify the kafka connection fail
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* don't enable consum retry in kafka binding component;if authenticaion is disabled, need not set TLSDisable at the same time;
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
* fix lint
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
Co-authored-by: Loong Dai <long.dai@intel.com>
2022-05-10 20:07:23 -07:00
Deepanshu Agarwal
Alessandro (Ale) Segala
Sky Ao