yabinmeng
c077218e8a
Fix example yaml file producer and consumer parameter names
2022-11-21 21:05:26 -06:00
yabinmeng
f7c9e50f35
Add README file and adjust sample yaml files
2022-11-19 18:53:58 -06:00
yabinmeng
bd8aff9081
Added support for 1) subscription initial position and 2) regex subscription mode
...
Also fixed a consumer configuration loading issue with dlq/negAck/ackTimeout policy using Pulsar client's loadConf() API.
Addressed the review comments in PR #791 ; reverted the changes in ActivityMetrics and BasedOpDispenser
2022-11-18 18:22:04 -06:00
yabinmeng
0de7102884
Add support for
...
1) producer message compression
2) consumer DLT/negAck/ackTimeout policy
Add sample NB scenario yaml files
2022-11-17 18:47:37 -06:00
yabinmeng
12f8697e0e
Complete the first draft of NB5 Pulsar adapter code, except the per-thread rate limiter.
2022-11-17 10:39:37 -06:00
yabinmeng
0c71696b15
Completed NB4 Pulsar driver code migration to NB5. But there are still a few lingering issues due to the difference of how NB4 vs NB5 driver/adapter interacts with the NB engine.
2022-11-16 15:37:26 -06:00
yabinmeng
ca6f2b052b
Add PulsarAdapter specific metrics
2022-11-14 15:27:57 -06:00
yabinmeng
c309d200ac
- Delete unsed code "driver-jms"
...
- NB5 Pulsar driver Admin functionality in place - create/delete tenant, namespace, and topic
2022-11-11 18:36:06 -06:00
