Fix data race in kafka_consumer_test.go (#7737)
This commit is contained in:
parent
7f3c30b8f2
commit
c06eef47e7
|
|
@ -289,7 +289,7 @@ func TestConsumerGroupHandler_ConsumeClaim(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
err = cg.ConsumeClaim(session, claim)
|
err := cg.ConsumeClaim(session, claim)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue