goroutine 7402664 [running]: runtime/pprof.writeGoroutineStacks({0x7f868a56ee10, 0xc00030be30}) /usr/local/go/src/runtime/pprof/pprof.go:761 +0x6a runtime/pprof.writeGoroutine({0x7f868a56ee10?, 0xc00030be30?}, 0xc00030bf20?) /usr/local/go/src/runtime/pprof/pprof.go:750 +0x25 runtime/pprof.(*Profile).WriteTo(0x24ad2a0?, {0x7f868a56ee10?, 0xc00030be30?}, 0xc?) /usr/local/go/src/runtime/pprof/pprof.go:374 +0x14b net/http/pprof.handler.ServeHTTP({0x11ca4d1, 0x9}, {0x1415420, 0xc00030be30}, 0xc0027f5680) /usr/local/go/src/net/http/pprof/pprof.go:272 +0x52f net/http.HandlerFunc.ServeHTTP(0xc000fa59b0?, {0x1415420?, 0xc00030be30?}, 0xc000fa59b0?) /usr/local/go/src/net/http/server.go:2220 +0x29 dsdrive/pkg/http.registerProfiler.NewFastHTTPHandlerFunc.NewFastHTTPHandler.func20(0xc0000fc608) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/fasthttpadaptor/adaptor.go:63 +0x151 dsdrive/pkg/http.registerProfiler.func9(0x1045320?) /build/pkg/http/profiler.go:89 +0x1e github.com/gofiber/fiber/v2.(*App).next(0xc000280f08, 0xc0016ff508) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/router.go:145 +0x1be github.com/gofiber/fiber/v2.(*App).handler(0xc000280f08, 0x4b0c0f?) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/router.go:172 +0x69 github.com/valyala/fasthttp.(*Server).serveConn(0xc00015cd88, {0x141d8b8, 0xc002042fc8}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:2394 +0x11b1 github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc0003a0f30, 0xc002bc6fa0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:225 +0x92 github.com/valyala/fasthttp.(*workerPool).getCh.func1() /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:197 +0x32 created by github.com/valyala/fasthttp.(*workerPool).getCh in goroutine 109 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:196 +0x194 goroutine 1 [chan receive, 21470 minutes]: dsdrive/pkg/app.(*App).waitForCompletion(0xc0003a0c60) /build/pkg/app/app.go:173 +0x7c dsdrive/pkg/app.(*App).run(0xc0003a0c60, 0x0?) /build/pkg/app/app.go:100 +0x125 dsdrive/pkg/app.Run(0xc000029f00) /build/pkg/app/app.go:68 +0xc6 dsdrive/pkg/cmd.Run(0x12d2fe8) /build/pkg/cmd/cmd.go:50 +0x14d main.main() /build/cmd/app/main.go:16 +0x1f goroutine 53 [select]: github.com/segmentio/kafka-go.(*connPool).discover(0xc0002c21c0, {0x1417e00, 0xc0001ba230}, 0xc00048c380) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/transport.go:631 +0x48b created by github.com/segmentio/kafka-go.(*Transport).grabPool in goroutine 1 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/transport.go:259 +0x585 goroutine 61 [select]: github.com/patrickmn/go-cache.(*janitor).Run(0xc00026f4e0, 0xc0001a2b80) /go/pkg/mod/github.com/patrickmn/go-cache@v2.1.0+incompatible/cache.go:1079 +0x7d created by github.com/patrickmn/go-cache.runJanitor in goroutine 1 /go/pkg/mod/github.com/patrickmn/go-cache@v2.1.0+incompatible/cache.go:1099 +0xdb goroutine 115 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.updateServerDate.func1() /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/header.go:2368 +0x18 created by github.com/valyala/fasthttp.updateServerDate in goroutine 114 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/header.go:2366 +0x1f goroutine 28 [select, 21470 minutes]: database/sql.(*DB).connectionOpener(0xc0001a41a0, {0x1417e00, 0xc00012e7d0}) /usr/local/go/src/database/sql/sql.go:1253 +0x87 created by database/sql.OpenDB in goroutine 1 /usr/local/go/src/database/sql/sql.go:833 +0x130 goroutine 26 [sync.Cond.Wait, 1152 minutes]: sync.runtime_notifyListWait(0xc00010f010, 0x4c) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0000b6d38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0000b6d20) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 1 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 62 [select]: github.com/patrickmn/go-cache.(*janitor).Run(0xc00026f530, 0xc0001a2c00) /go/pkg/mod/github.com/patrickmn/go-cache@v2.1.0+incompatible/cache.go:1079 +0x7d created by github.com/patrickmn/go-cache.runJanitor in goroutine 1 /go/pkg/mod/github.com/patrickmn/go-cache@v2.1.0+incompatible/cache.go:1099 +0xdb goroutine 106 [select, 1312 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000e324c0, {0x1417e00, 0xc0001babe0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x1417d20?, 0x24fe980?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/app/services/local.NewLocalService.func1.4() /build/internal/app/services/local/service.go:83 +0x29 dsdrive/pkg/app.(*App).Go.func1() /build/pkg/app/app.go:218 +0x50 created by dsdrive/pkg/app.(*App).Go in goroutine 1 /build/pkg/app/app.go:209 +0xb5 goroutine 69 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*workerPool).Start.func2() /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:68 +0x50 created by github.com/valyala/fasthttp.(*workerPool).Start in goroutine 110 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:60 +0xc5 goroutine 81 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*TCPDialer).tcpAddrsClean(0x24c5380) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/tcpdialer.go:413 +0x29 created by github.com/valyala/fasthttp.(*TCPDialer).dial.func1 in goroutine 1 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/tcpdialer.go:285 +0xb6 goroutine 105 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000e32480, {0x1417e00, 0xc0001bac80}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x1417d20?, 0x24fe980?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/app/services/local.NewLocalService.func1.3() /build/internal/app/services/local/service.go:77 +0x29 dsdrive/pkg/app.(*App).Go.func1() /build/pkg/app/app.go:218 +0x50 created by dsdrive/pkg/app.(*App).Go in goroutine 1 /build/pkg/app/app.go:209 +0xb5 goroutine 104 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000e32440, {0x1417e00, 0xc0001bac30}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x1417d20?, 0x24fe980?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/app/services/local.NewLocalService.func1.2() /build/internal/app/services/local/service.go:71 +0x29 dsdrive/pkg/app.(*App).Go.func1() /build/pkg/app/app.go:218 +0x50 created by dsdrive/pkg/app.(*App).Go in goroutine 1 /build/pkg/app/app.go:209 +0xb5 goroutine 48 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0001763c0, 0xc000304690) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 47 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 107 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc0001a2c80, {0x1417e00, 0xc000355d10}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x1417d20?, 0x24fe980?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/app/services/usersync.New.func2.2() /build/internal/app/services/usersync/service.go:60 +0x29 dsdrive/pkg/app.(*App).Go.func1() /build/pkg/app/app.go:218 +0x50 created by dsdrive/pkg/app.(*App).Go in goroutine 1 /build/pkg/app/app.go:209 +0xb5 goroutine 108 [select, 51 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000e139c0, {0x1417e00, 0xc000355d60}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x1417d20?, 0x24fe980?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/app/services/wopi.New.func2.2() /build/internal/app/services/wopi/service.go:90 +0x29 dsdrive/pkg/app.(*App).Go.func1() /build/pkg/app/app.go:218 +0x50 created by dsdrive/pkg/app.(*App).Go in goroutine 1 /build/pkg/app/app.go:209 +0xb5 goroutine 109 [IO wait]: internal/poll.runtime_pollWait(0x7f868a613e68, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc000346780?, 0xc0001aba98?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0x27 internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Accept(0xc000346780) /usr/local/go/src/internal/poll/fd_unix.go:620 +0x295 net.(*netFD).accept(0xc000346780) /usr/local/go/src/net/fd_unix.go:172 +0x29 net.(*TCPListener).accept(0xc00010f400) /usr/local/go/src/net/tcpsock_posix.go:159 +0x1e net.(*TCPListener).Accept(0xc00010f400) /usr/local/go/src/net/tcpsock.go:372 +0x30 github.com/valyala/fasthttp.acceptConn(0xc00015cd88, {0x14158b0, 0xc00010f400}, 0xc0001abdc8) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1929 +0x55 github.com/valyala/fasthttp.(*Server).Serve(0xc00015cd88, {0x14158b0, 0xc00010f400}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1823 +0x4d2 github.com/gofiber/fiber/v2.(*App).Listener(0xc000280f08, {0x14158b0, 0xc00010f400}) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/listen.go:57 +0x1fd dsdrive/internal/app.Run.(*ProfilingServer).StartProfServer.func3.2() /build/pkg/http/profiler.go:39 +0xd3 dsdrive/pkg/app.(*App).Go.func1() /build/pkg/app/app.go:218 +0x50 created by dsdrive/pkg/app.(*App).Go in goroutine 1 /build/pkg/app/app.go:209 +0xb5 goroutine 110 [IO wait]: internal/poll.runtime_pollWait(0x7f868a613f80, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc000159500?, 0x900000036?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0x27 internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Accept(0xc000159500) /usr/local/go/src/internal/poll/fd_unix.go:620 +0x295 net.(*netFD).accept(0xc000159500) /usr/local/go/src/net/fd_unix.go:172 +0x29 net.(*TCPListener).accept(0xc000e32540) /usr/local/go/src/net/tcpsock_posix.go:159 +0x1e net.(*TCPListener).Accept(0xc000e32540) /usr/local/go/src/net/tcpsock.go:372 +0x30 github.com/valyala/fasthttp.acceptConn(0xc00015cfc8, {0x14158b0, 0xc000e32540}, 0xc00001ad50) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1929 +0x55 github.com/valyala/fasthttp.(*Server).Serve(0xc00015cfc8, {0x14158b0, 0xc000e32540}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1823 +0x4d2 github.com/gofiber/fiber/v2.(*App).Listener(0xc000281408, {0x14158b0, 0xc000e32540}) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/listen.go:57 +0x1fd dsdrive/pkg/http.InitServer.func8.2() /build/pkg/http/server.go:150 +0x116 dsdrive/pkg/app.(*App).Go.func1() /build/pkg/app/app.go:218 +0x50 created by dsdrive/pkg/app.(*App).Go in goroutine 1 /build/pkg/app/app.go:209 +0xb5 goroutine 112 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*workerPool).Start.func2() /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:68 +0x50 created by github.com/valyala/fasthttp.(*workerPool).Start in goroutine 109 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:60 +0xc5 goroutine 42 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc000176640, 0xc0000c1da0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 114 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 95 [syscall, 21470 minutes]: os/signal.signal_recv() /usr/local/go/src/runtime/sigqueue.go:152 +0x29 os/signal.loop() /usr/local/go/src/os/signal/signal_unix.go:23 +0x13 created by os/signal.Notify.func1.1 in goroutine 1 /usr/local/go/src/os/signal/signal.go:151 +0x1f goroutine 96 [select, 21470 minutes]: os/signal.NotifyContext.func1() /usr/local/go/src/os/signal/signal.go:288 +0x66 created by os/signal.NotifyContext in goroutine 1 /usr/local/go/src/os/signal/signal.go:287 +0x156 goroutine 113 [select, 21470 minutes]: dsdrive/pkg/app.(*App).notifyCompletion(0xc0003a0c60) /build/pkg/app/app.go:108 +0x88 created by dsdrive/pkg/app.(*App).run in goroutine 1 /build/pkg/app/app.go:99 +0x116 goroutine 43 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0003e2340) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 114 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 1188 [sync.Cond.Wait, 3918 minutes]: sync.runtime_notifyListWait(0xc001432c50, 0x45) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001604018) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001604000) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 1040 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 145 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0003e2680) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 47 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 623 [sync.Cond.Wait, 3916 minutes]: sync.runtime_notifyListWait(0xc000e12d50, 0x3d) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00101b6f8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00101b6e0) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 470 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 667 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc0010d81d0, 0x45) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000100000000?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0003a4bb8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0003a4ba0) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 583 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 619 [sync.Cond.Wait, 1150 minutes]: sync.runtime_notifyListWait(0xc000e12b50, 0x45) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000100000000?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00101b638) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00101b620) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 583 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 673 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc00105d850, 0x4d) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x24da6c0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000f14a38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f14a20) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 583 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 5676210 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc00157e4e0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 5676182 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 526 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc00010ff50, 0x4f) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x20032be01?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000e0e2b8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000e0e2a0) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 492 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 5706645 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc001e37900, 0xc0028aa540) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 5706644 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 559 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc001074ad0, 0x49) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x24da6c0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000e0ee58) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000e0ee40) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 470 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 637 [sync.Cond.Wait, 3916 minutes]: sync.runtime_notifyListWait(0xc001411490, 0x44) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x1000200000000?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0003a4138) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0003a4120) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 583 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 692 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc000f93e90, 0x51) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x1000200000000?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000f08df8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f08de0) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 470 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1029 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc000f93c10, 0x47) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000d95038) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000d95020) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 1028 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 631 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc001411350, 0x47) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001255ed8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001255ec0) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 556 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 606 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc000f92610, 0x44) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc000f03f18?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000f08798) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f08780) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 470 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 539 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc0003911d0, 0x45) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc0001a6f98?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0000b6f78) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0000b6f60) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 492 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 565 [sync.Cond.Wait, 3918 minutes]: sync.runtime_notifyListWait(0xc000391b50, 0x4b) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0000b7578) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0000b7560) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 556 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 567 [sync.Cond.Wait, 3910 minutes]: sync.runtime_notifyListWait(0xc000391e90, 0x47) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0000b7758) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0000b7740) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 492 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 554 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc000e32650, 0x4b) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x1?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000e0ea98) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000e0ea80) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 492 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 639 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc001411690, 0x41) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0003a4258) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0003a4240) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 470 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 586 [sync.Cond.Wait, 3916 minutes]: sync.runtime_notifyListWait(0xc001074ed0, 0x4f) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000e0f038) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000e0f020) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 556 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1086 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc0010565d0, 0x46) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00107c078) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00107c060) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 1040 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1037 [sync.Cond.Wait, 1152 minutes]: sync.runtime_notifyListWait(0xc001154290, 0x4c) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000000000000?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000d957b8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000d957a0) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 1028 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1059 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc001221350, 0x43) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc0001a8da7?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001254978) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001254960) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 470 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1203 [sync.Cond.Wait, 1158 minutes]: sync.runtime_notifyListWait(0xc0015a5490, 0x47) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x200000000?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00107ca38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00107ca20) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 1028 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1124 [sync.Cond.Wait, 1160 minutes]: sync.runtime_notifyListWait(0xc001432210, 0x3b) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc001313da7?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0003a4e58) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0003a4e40) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:1013 +0x38 github.com/segmentio/kafka-go.(*Writer).spawn.func1() /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:547 +0x53 created by github.com/segmentio/kafka-go.(*Writer).spawn in goroutine 1028 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 5676209 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc000ef7680, 0xc00030abd0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 5676182 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 5706646 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc000129ba0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 5706644 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 7402527 [IO wait]: internal/poll.runtime_pollWait(0x7f868a48aed0, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc002c70900?, 0xc00275e000?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0x27 internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc002c70900, {0xc00275e000, 0x2000, 0x2000}) /usr/local/go/src/internal/poll/fd_unix.go:165 +0x27a net.(*netFD).Read(0xc002c70900, {0xc00275e000?, 0x1000000800572?, 0xc000e689a0?}) /usr/local/go/src/net/fd_posix.go:55 +0x25 net.(*conn).Read(0xc0000cf098, {0xc00275e000?, 0xc002ad1d40?, 0xc00275e0f6?}) /usr/local/go/src/net/net.go:189 +0x45 crypto/tls.(*atLeastReader).Read(0xc00222aff0, {0xc00275e000?, 0x0?, 0xc00222aff0?}) /usr/local/go/src/crypto/tls/conn.go:809 +0x3b bytes.(*Buffer).ReadFrom(0xc001d2cd38, {0x140c980, 0xc00222aff0}) /usr/local/go/src/bytes/buffer.go:211 +0x98 crypto/tls.(*Conn).readFromUntil(0xc001d2ca88, {0x140a180, 0xc0000cf098}, 0xc000e68a10?) /usr/local/go/src/crypto/tls/conn.go:831 +0xde crypto/tls.(*Conn).readRecordOrCCS(0xc001d2ca88, 0x0) /usr/local/go/src/crypto/tls/conn.go:629 +0x3cf crypto/tls.(*Conn).readRecord(...) /usr/local/go/src/crypto/tls/conn.go:591 crypto/tls.(*Conn).Read(0xc001d2ca88, {0xc002021000, 0x1000, 0xc0015f8e00?}) /usr/local/go/src/crypto/tls/conn.go:1385 +0x150 bufio.(*Reader).Read(0xc002d25c20, {0xc0012344a0, 0x9, 0x24a9000?}) /usr/local/go/src/bufio/bufio.go:241 +0x197 io.ReadAtLeast({0x14099c0, 0xc002d25c20}, {0xc0012344a0, 0x9, 0x9}, 0x9) /usr/local/go/src/io/io.go:335 +0x90 io.ReadFull(...) /usr/local/go/src/io/io.go:354 net/http.http2readFrameHeader({0xc0012344a0, 0x9, 0xc0024b7170?}, {0x14099c0?, 0xc002d25c20?}) /usr/local/go/src/net/http/h2_bundle.go:1642 +0x65 net/http.(*http2Framer).ReadFrame(0xc001234460) /usr/local/go/src/net/http/h2_bundle.go:1909 +0x85 net/http.(*http2clientConnReadLoop).run(0xc000e68fa8) /usr/local/go/src/net/http/h2_bundle.go:9496 +0xda net/http.(*http2ClientConn).readLoop(0xc001f0c300) /usr/local/go/src/net/http/h2_bundle.go:9392 +0x7c created by net/http.(*http2Transport).newClientConn in goroutine 7402526 /usr/local/go/src/net/http/h2_bundle.go:8006 +0xd1b goroutine 7110382 [chan receive]: github.com/segmentio/kafka-go.(*conn).run(0xc001fdf770, 0xc0014d51c0, 0xc0012d1960) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/transport.go:1257 +0x99 created by github.com/segmentio/kafka-go.(*connGroup).connect in goroutine 7110386 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/transport.go:1235 +0xd31