small fix with Gosched

msales · Oct 5, 2021 · 97180a7 · 97180a7
1 parent 4e2ccd2
commit 97180a7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/source.go b/kafka/source.go
@@ -265,9 +265,9 @@ func (s *Source) Commit(v interface{}) error {
 	// If commit strategy is not CommitAuto, session should perform global, synchronous commit of current marked offsets.
 	if s.commitStrategy != CommitAuto {
 		s.session.Commit()
+		runtime.Gosched() // If any error from consumer side happens after Commiting, it will be read and s.lastErr will be set.
 	}
 
-	runtime.Gosched() // If any error from consumer side happens after Commiting, it will be read and s.lastErr will be set.
 	return s.lastErr
 }