group/commit: return error if offset determined from timestamp is -1

birdayz · Apr 8, 2020 · 4683122 · 4683122
1 parent 4fd7f94
commit 4683122
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/cmd/kaf/group.go b/cmd/kaf/group.go
@@ -139,6 +139,11 @@ func createGroupCommitOffsetCmd() *cobra.Command {
 				if err != nil {
 					errorExit("Failed to determine offset for timestamp: %v", err)
 				}
+
+				if o == -1 {
+					errorExit("Determined offset -1 from timestamp. Skipping.", o)
+				}
+
 				off = o
 
 				fmt.Printf("Determined offset %v from timestamp.\n", off)