diff --git a/consumer_test.go b/consumer_test.go index 111275c..2481cf8 100644 --- a/consumer_test.go +++ b/consumer_test.go @@ -3,10 +3,11 @@ package kafka import ( "context" "errors" - "github.com/segmentio/kafka-go" "sync" "testing" "time" + + "github.com/segmentio/kafka-go" ) func Test_consumer_startBatch(t *testing.T) {