Merge pull request #14 from zerodha/develop

Adds go-releaser and fixes lag threshold logic

Author: joeirimpan

.github/workflows/release.yml

@@ -0,0 +1,31 @@
+name: goreleaser
+
+on:
+  push:
+    tags:
+      - "v*" # Will trigger only if tag is pushed matching pattern `v*` (Eg: `v0.1.0`)
+
+permissions:
+  contents: write
+
+jobs:
+  goreleaser:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
+
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: "1.21"
+
+      - name: Run GoReleaser
+        uses: goreleaser/goreleaser-action@v5
+        with:
+          version: latest
+          args: release --clean
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.goreleaser.yml

@@ -1,22 +1,19 @@
-env:
-  - CGO_ENABLED=1
-
 before:
   hooks:
-  - make dist
-
+    - go mod tidy
+  
 builds:
-  - binary: kaf-relay.bin
-    main: .
+  - env:
+      - CGO_ENABLED=1
+    binary: kaf-relay
     goos:
-      - windows
       - linux
-      - netbsd
     goarch:
       - amd64
 
 archives:
   - format: tar.gz
     files:
+      - config.toml.sample
       - README.md
       - LICENSE

utils.go

@@ -349,25 +349,21 @@ func waitTries(ctx context.Context, b time.Duration) {
 	}
 }
 
-// thresholdExceeded checks if the difference between the offsets is breaching the threshold
+// thresholdExceeded checks if the difference between the sum of offsets in all topics is breaching the threshold
 func thresholdExceeded(offsetsX, offsetsY kadm.ListedOffsets, max int64) bool {
+	var diff int64
 	for t, po := range offsetsX {
 		for p, x := range po {
 			y, ok := offsetsY.Lookup(t, p)
 			if !ok {
 				continue
 			}
 
-			// check if the difference is breaching threshold
-			if y.Offset < x.Offset {
-				if (x.Offset - y.Offset) >= max {
-					return true
-				}
-			}
+			diff += (x.Offset - y.Offset)
 		}
 	}
 
-	return false
+	return diff >= max
 }
 
 // isCurrentNode checks if group is active and assigned the topics