nats-io / nats-kafka

NATS to Kafka Bridging
Apache License 2.0
131 stars 32 forks source link

Add QueueSubscriber Option for JetstreamToKafka #89

Closed aonurdemir closed 11 months ago

aonurdemir commented 1 year ago

This PR adds a feature that provides connecting a jetstream with multiple push subscribers with a queue group in order to provide horizontal scalability and fault tolerance support.

This may be a solution to the issue #88

codecov[bot] commented 1 year ago

Codecov Report

Patch coverage: 75.00% and project coverage change: -0.02% :warning:

Comparison is base (51f7863) 66.50% compared to head (5d38ab3) 66.48%. Report is 2 commits behind head on main.

:exclamation: Current head 5d38ab3 differs from pull request most recent head 8b58afd. Consider uploading reports for the commit 8b58afd to get more accurate results

Additional details and impacted files ```diff @@ Coverage Diff @@ ## main #89 +/- ## ========================================== - Coverage 66.50% 66.48% -0.02% ========================================== Files 28 28 Lines 1821 1823 +2 ========================================== + Hits 1211 1212 +1 - Misses 481 482 +1 Partials 129 129 ``` | [Files Changed](https://app.codecov.io/gh/nats-io/nats-kafka/pull/89?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=nats-io) | Coverage Δ | | |---|---|---| | [server/core/connector.go](https://app.codecov.io/gh/nats-io/nats-kafka/pull/89?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=nats-io#diff-c2VydmVyL2NvcmUvY29ubmVjdG9yLmdv) | `77.50% <66.66%> (-0.20%)` | :arrow_down: | | [server/core/jetstream2kafka.go](https://app.codecov.io/gh/nats-io/nats-kafka/pull/89?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=nats-io#diff-c2VydmVyL2NvcmUvamV0c3RyZWFtMmthZmthLmdv) | `79.31% <100.00%> (ø)` | |

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.