[hot fix] errNotAvailable => errNotAvailableWithGroup

brzyangg · Feb 22, 2018 · c4aa0f7 · c4aa0f7
1 parent f9bd146
commit c4aa0f7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/reader.go b/reader.go
@@ -28,7 +28,6 @@ const (
 )
 
 var (
-	// errNotAvailable returned when func called that is not supported in cluster mode
 	errOnlyAvailableWithGroup = errors.New("unavailable when GroupID is not set")
 	errNotAvailableWithGroup  = errors.New("unavailable when GroupID is set")
 )

diff --git a/reader_test.go b/reader_test.go
@@ -502,8 +502,8 @@ func testConsumerGroupSimple(t *testing.T, ctx context.Context, r *Reader) {
 
 func TestReaderSetOffsetWhenConsumerGroupsEnabled(t *testing.T) {
 	r := &Reader{config: ReaderConfig{GroupID: "not-zero"}}
-	if err := r.SetOffset(-1); err != errNotAvailable {
-		t.Fatalf("expected %v; got %v", errNotAvailable, err)
+	if err := r.SetOffset(-1); err != errNotAvailableWithGroup {
+		t.Fatalf("expected %v; got %v", errNotAvailableWithGroup, err)
 	}
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -28,7 +28,6 @@ const ( @@
     )
     var (
-    	// errNotAvailable returned when func called that is not supported in cluster mode
     	errOnlyAvailableWithGroup = errors.New("unavailable when GroupID is not set")
     	errNotAvailableWithGroup  = errors.New("unavailable when GroupID is set")
     )
@@ Expand Down @@