Releases
v0.0.1
Changelog
511e9f3 Merge pull request #14 from zerodha/develop
cda17e3 fix: check offsets across topics for lag
b0e944c chore: add goreleaser
ba4d0d8 Merge pull request #13 from zerodha/develop
eac33a4 ref: Use kadm leave group builder, instance id config
2623847 Apply minor changes and improvements to README
a46ec5d feat: optional partition mapping for producer
26465cd feat: pass context to assinged cb
0e1c458 refactor: replace bg worker with parallel check instead of serial
3fc03ce fix: Use static member (instance id)
3528860 feat: Use topic lag check to track healthy node and remove hooks
e627b98 refactor: minor fixes after test scenarios fix: use single client connection fix: ctx cancellation in start func
754c9c7 feat: Migrate from async to sync produce with batching
1615a8d refactor: use async consumer and related offset changes
adf1559 feat: Failover when topic is lagging behind
b2ddcb2 Merge pull request #5 from kalbhor/main
7640f11 fix: check for tls config in producer
b500d3c fix: use koanf tag for tls params
5ca9c97 fix: remove darwin from build matrix
dcbf6ad fix: change CGO_ENABLED for support plugins in goreleaser
6107128 doc: Fix readme
f3731ee Merge pull request #4 from joeirimpan/filter-plugin
31ad4db feat: Filter messages using go plugin filter providers
77ee6b5 Merge pull request #3 from joeirimpan/end
662d098 feat: Add ability to stop on end of offsets fetched on boot
637f3c6 chore: Update relay image
0511991 Merge pull request #2 from joeirimpan/fallbacks
ba674e0 ref: Upgrade franz-go, use LeaveGroupContext, minor refs
c9ab265 fix: Keep multiple topics offsets in mem
10c5b61 docs: Add note in kaf-relay on consumer group failover
41f557c fix: Remove local replace for franz-go
4903995 feat: Add backoff for initial consumer group init
c59f57b feat: Checkpoint current group id, offsets to disk
2aacf9e feat: Add single/failover modes to plug in OnBrokerDisconnect hooks conditionally
8cf200b feat: Wait for topic lag to catch up when we failover
4849da2 feat: consumer group failover
5726bd8 ref: Upgrade franz-go, migrating to slog
749d764 fix: Fix manual commit offset, use sync commit
04e6d0d feat: Flatten embedded struct without manual unmarshal
fe36bc4 chore: Add ztech sticker
ac3de82 chore: go mod tidy + mod rename
8e189d6 chore: Add goreleaser.yml
53f27fc chore: Add metrics docs + cleanup
c050ec3 feat: Add prom metrics
97508b5 doc: Reword README.md
70a2325 feat: Add SCRAM auth, use manually partitioner by default
d3e5f59 feat: Mark commit offsets + readme
9bf48a3 feat: Initial commit
ad65c66 Initial commit
You can’t perform that action at this time.