goroutine 337322 [running]: runtime/pprof.writeGoroutineStacks({0x7f2340dea718, 0xc0002fd0b0}) /usr/local/go/src/runtime/pprof/pprof.go:761 +0x6a runtime/pprof.writeGoroutine({0x7f2340dea718?, 0xc0002fd0b0?}, 0xc0002fd1a0?) /usr/local/go/src/runtime/pprof/pprof.go:750 +0x25 runtime/pprof.(*Profile).WriteTo(0x24bf210?, {0x7f2340dea718?, 0xc0002fd0b0?}, 0xc?) /usr/local/go/src/runtime/pprof/pprof.go:374 +0x14b net/http/pprof.handler.ServeHTTP({0x11c284f, 0x9}, {0x141b820, 0xc0002fd0b0}, 0xc0000b97c0) /usr/local/go/src/net/http/pprof/pprof.go:272 +0x52f net/http.HandlerFunc.ServeHTTP(0xc000eaf9b0?, {0x141b820?, 0xc0002fd0b0?}, 0xc000eaf9b0?) /usr/local/go/src/net/http/server.go:2220 +0x29 dsdrive/pkg/http.registerProfiler.NewFastHTTPHandlerFunc.NewFastHTTPHandler.func20(0xc000fdf208) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/fasthttpadaptor/adaptor.go:63 +0x151 dsdrive/pkg/http.registerProfiler.func9(0x1044480?) /build/pkg/http/profiler.go:89 +0x1e github.com/gofiber/fiber/v2.(*App).next(0xc0001a0a08, 0xc001586908) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/router.go:145 +0x1be github.com/gofiber/fiber/v2.(*App).handler(0xc0001a0a08, 0x4b0d2f?) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/router.go:172 +0x69 github.com/valyala/fasthttp.(*Server).serveConn(0xc000cdb8c8, {0x1423cb8, 0xc001308140}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:2394 +0x11b1 github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc000cd86c0, 0xc002316040) /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, 593 minutes]: dsdrive/pkg/app.(*App).waitForCompletion(0xc00032c360) /build/pkg/app/app.go:173 +0x7c dsdrive/pkg/app.(*App).run(0xc00032c360, 0x0?) /build/pkg/app/app.go:100 +0x125 dsdrive/pkg/app.Run(0xc000379ef8) /build/pkg/app/app.go:68 +0xc6 dsdrive/pkg/cmd.Run(0x12da780) /build/pkg/cmd/cmd.go:50 +0x14d main.main() /build/cmd/services/dsdrive/main.go:16 +0x2b goroutine 146 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc000259380) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 106 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 101 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f55d80, {0x141e200, 0xc00018d9a0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/local.NewLocalService.func1.2() /build/internal/components/webdisk/services/local/service.go:79 +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 34 [select]: github.com/segmentio/kafka-go.(*connPool).discover(0xc0002521c0, {0x141e200, 0xc000230050}, 0xc000cf0070) /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 56 [chan receive]: github.com/segmentio/kafka-go.(*conn).run(0xc00031c4b0, 0xc0002fe8c0, 0xc000342770) /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 35 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/transport.go:1235 +0xd31 goroutine 40 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc000057550, 0x3b) /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(0xc000cf4798) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000cf4780) /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 42 [select, 593 minutes]: database/sql.(*DB).connectionOpener(0xc000ccca90, {0x141e200, 0xc0002301e0}) /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 59 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*TCPDialer).tcpAddrsClean(0x24d7200) /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 67 [select, 4 minutes]: github.com/patrickmn/go-cache.(*janitor).Run(0xc000cc9310, 0xc000e5c000) /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 68 [select, 2 minutes]: github.com/patrickmn/go-cache.(*janitor).Run(0xc000cc97a0, 0xc000e5c0c0) /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 69 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc00027e000, 0xc000291e00) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 1 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 163 [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 162 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/header.go:2366 +0x1f goroutine 148 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc000275e00, 0xc0002bcff0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 161 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 82 [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 103 [select, 593 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f55e00, {0x141e200, 0xc00031caf0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/local.NewLocalService.func1.4() /build/internal/components/webdisk/services/local/service.go:91 +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 102 [select, 4 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f55dc0, {0x141e200, 0xc000800be0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/local.NewLocalService.func1.3() /build/internal/components/webdisk/services/local/service.go:85 +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, 2 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f55e40, {0x141e200, 0xc00018d950}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/local.NewLocalService.func1.5() /build/internal/components/webdisk/services/local/service.go:97 +0x2c 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 105 [select, 24 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f55e80, {0x141e200, 0xc0002d29b0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/forwarder.NewForwarder.func1.2() /build/internal/components/webdisk/services/forwarder/service.go:112 +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 106 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f55ec0, {0x141e200, 0xc0002d2a00}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/forwarder.NewForwarder.func1.3() /build/internal/components/webdisk/services/forwarder/service.go:118 +0x2c 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 107 [select, 54 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f54080, {0x141e200, 0xc0002d2a50}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/wopi.New.func2.2() /build/internal/components/webdisk/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 108 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000f54100, {0x141e200, 0xc0002d2aa0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x141e120?, 0x25107a0?}) /build/pkg/job/job.go:60 +0xcb dsdrive/pkg/job.(*Job).Run(...) /build/pkg/job/job.go:40 dsdrive/internal/components/webdisk/services/usersync.New.func2.2() /build/internal/components/webdisk/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 109 [IO wait]: internal/poll.runtime_pollWait(0x7f23410bf810, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc000fb4200?, 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(0xc000fb4200) /usr/local/go/src/internal/poll/fd_unix.go:620 +0x295 net.(*netFD).accept(0xc000fb4200) /usr/local/go/src/net/fd_unix.go:172 +0x29 net.(*TCPListener).accept(0xc000f55f40) /usr/local/go/src/net/tcpsock_posix.go:159 +0x1e net.(*TCPListener).Accept(0xc000f55f40) /usr/local/go/src/net/tcpsock.go:372 +0x30 github.com/valyala/fasthttp.acceptConn(0xc000cdb8c8, {0x141bd10, 0xc000f55f40}, 0xc0006f8dc8) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1929 +0x55 github.com/valyala/fasthttp.(*Server).Serve(0xc000cdb8c8, {0x141bd10, 0xc000f55f40}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1823 +0x4d2 github.com/gofiber/fiber/v2.(*App).Listener(0xc0001a0a08, {0x141bd10, 0xc000f55f40}) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/listen.go:57 +0x1fd dsdrive/internal/components/webdisk.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(0x7f23410bf6f8, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc000249b80?, 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(0xc000249b80) /usr/local/go/src/internal/poll/fd_unix.go:620 +0x295 net.(*netFD).accept(0xc000249b80) /usr/local/go/src/net/fd_unix.go:172 +0x29 net.(*TCPListener).accept(0xc0002fef00) /usr/local/go/src/net/tcpsock_posix.go:159 +0x1e net.(*TCPListener).Accept(0xc0002fef00) /usr/local/go/src/net/tcpsock.go:372 +0x30 github.com/valyala/fasthttp.acceptConn(0xc000cdbb08, {0x141bd10, 0xc0002fef00}, 0xc0000b1d30) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1929 +0x55 github.com/valyala/fasthttp.(*Server).Serve(0xc000cdbb08, {0x141bd10, 0xc0002fef00}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1823 +0x4d2 github.com/gofiber/fiber/v2.(*App).Listener(0xc0001a0f08, {0x141bd10, 0xc0002fef00}) /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:161 +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 131 [select, 593 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 145 [syscall, 593 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 132 [select, 593 minutes]: dsdrive/pkg/app.(*App).notifyCompletion(0xc00032c360) /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 149 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc000fae9c0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 161 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 333040 [select]: net/http.(*persistConn).writeLoop(0xc000e3b200) /usr/local/go/src/net/http/transport.go:2519 +0xe7 created by net/http.(*Transport).dialConn in goroutine 333033 /usr/local/go/src/net/http/transport.go:1875 +0x15a5 goroutine 1314 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc001521d10, 0x41) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000000000001?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0016ffb78) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0016ffb60) /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 842 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1595 [sync.Cond.Wait]: sync.runtime_notifyListWait(0xc00067f0d0, 0x3d) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x24ec4e0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001896858) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001896840) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1790 [sync.Cond.Wait, 16 minutes]: sync.runtime_notifyListWait(0xc001808c50, 0x42) /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(0xc001897c38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001897c20) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1322 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc001736190, 0x40) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc001003f18?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0016ffc98) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0016ffc80) /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 842 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1758 [sync.Cond.Wait, 31 minutes]: sync.runtime_notifyListWait(0xc0017f77d0, 0x43) /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(0xc000f84c78) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f84c60) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 855 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc00101e810, 0x3e) /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(0xc000e8bbd8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000e8bbc0) /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 842 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1296 [sync.Cond.Wait, 25 minutes]: sync.runtime_notifyListWait(0xc0014ffc10, 0x3c) /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(0xc0014d7c38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0014d7c20) /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 842 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1161 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc00123b350, 0x4d) /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(0xc00129c858) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00129c840) /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 842 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1168 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc00123b7d0, 0x3c) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x101607288?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00129ca38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00129ca20) /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 842 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1623 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0014df1e0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 1335 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 337363 [IO wait]: internal/poll.runtime_pollWait(0x7f23410bfa40, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc0019f0000?, 0xc002081000?, 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(0xc0019f0000, {0xc002081000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:165 +0x27a net.(*netFD).Read(0xc0019f0000, {0xc002081000?, 0x0?, 0xc0019b8000?}) /usr/local/go/src/net/fd_posix.go:55 +0x25 net.(*conn).Read(0xc001308008, {0xc002081000?, 0xa7fa1f?, 0xc001808080?}) /usr/local/go/src/net/net.go:189 +0x45 bufio.(*Reader).fill(0xc002092480) /usr/local/go/src/bufio/bufio.go:110 +0x103 bufio.(*Reader).Peek(0xc002092480, 0x1) /usr/local/go/src/bufio/bufio.go:148 +0x53 github.com/valyala/fasthttp.(*Server).serveConn(0xc000cdb8c8, {0x1423cb8, 0xc001308008}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:2202 +0x805 github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc000cd86c0, 0xc001d8e040) /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 1621 [sync.Cond.Wait, 25 minutes]: sync.runtime_notifyListWait(0xc000f20d50, 0x3e) /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(0xc0012eef18) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0012eef00) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1369 [sync.Cond.Wait, 4 minutes]: sync.runtime_notifyListWait(0xc00037f8d0, 0x47) /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(0xc001896618) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001896600) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1739 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc0016520d0, 0x49) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc0000aef18?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0018973f8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0018973e0) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1412 [sync.Cond.Wait, 25 minutes]: sync.runtime_notifyListWait(0xc00077e610, 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(0xc00129c918) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00129c900) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1414 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc000cdd590, 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(0xc00129d6f8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00129d6e0) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1903 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc001b27290, 0x3c) /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(0xc00067a198) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00067a180) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1687 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc000facd90, 0x42) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc0013b2f18?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001896d38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001896d20) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1502 [sync.Cond.Wait, 2 minutes]: sync.runtime_notifyListWait(0xc001280790, 0x3f) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x6f796d2e73636f01?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0019874b8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0019874a0) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1608 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc001371c10, 0x3e) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x25107a0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00009ff38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00009ff20) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1697 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc00158b790, 0x3b) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x20188b718?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000e8a678) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000e8a660) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1647 [sync.Cond.Wait, 25 minutes]: sync.runtime_notifyListWait(0xc001522490, 0x3e) /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(0xc0019879f8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0019879e0) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1665 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc001522790, 0x39) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x24ec4e0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001987b78) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001987b60) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1728 [sync.Cond.Wait, 20 minutes]: sync.runtime_notifyListWait(0xc0017aa150, 0x43) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x24ec4e0?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000f84438) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f84420) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 1660 [sync.Cond.Wait, 24 minutes]: sync.runtime_notifyListWait(0xc0013b4c10, 0x44) /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(0xc000f30df8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f30de0) /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 1335 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 336889 [chan receive]: github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc000db8240, 0xc001d19440) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:220 +0x53 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 110 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:196 +0x194 goroutine 337553 [chan receive]: github.com/segmentio/kafka-go.(*conn).run(0xc000230320, 0xc0017abe80, 0xc0000aa850) /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 337533 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/transport.go:1235 +0xd31 goroutine 333039 [IO wait]: internal/poll.runtime_pollWait(0x7f2340fe4418, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc001240780?, 0xc00180a000?, 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(0xc001240780, {0xc00180a000, 0x2500, 0x2500}) /usr/local/go/src/internal/poll/fd_unix.go:165 +0x27a net.(*netFD).Read(0xc001240780, {0xc00180a000?, 0x41072f?, 0xc000eb19d0?}) /usr/local/go/src/net/fd_posix.go:55 +0x25 net.(*conn).Read(0xc000344140, {0xc00180a000?, 0xc001dba400?, 0x562d13?}) /usr/local/go/src/net/net.go:189 +0x45 crypto/tls.(*atLeastReader).Read(0xc001274c30, {0xc00180a000?, 0x0?, 0xc001274c30?}) /usr/local/go/src/crypto/tls/conn.go:809 +0x3b bytes.(*Buffer).ReadFrom(0xc000f649b8, {0x1412c20, 0xc001274c30}) /usr/local/go/src/bytes/buffer.go:211 +0x98 crypto/tls.(*Conn).readFromUntil(0xc000f64708, {0x1410fa0, 0xc000344140}, 0xc000eb1a40?) /usr/local/go/src/crypto/tls/conn.go:831 +0xde crypto/tls.(*Conn).readRecordOrCCS(0xc000f64708, 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(0xc000f64708, {0xc000e35000, 0x1000, 0xc000606508?}) /usr/local/go/src/crypto/tls/conn.go:1385 +0x150 net/http.(*persistConn).Read(0xc000e3b200, {0xc000e35000?, 0x843e65?, 0x1042fe0?}) /usr/local/go/src/net/http/transport.go:2052 +0x4a bufio.(*Reader).fill(0xc001ae1a40) /usr/local/go/src/bufio/bufio.go:110 +0x103 bufio.(*Reader).Peek(0xc001ae1a40, 0x1) /usr/local/go/src/bufio/bufio.go:148 +0x53 net/http.(*persistConn).readLoop(0xc000e3b200) /usr/local/go/src/net/http/transport.go:2205 +0x185 created by net/http.(*Transport).dialConn in goroutine 333033 /usr/local/go/src/net/http/transport.go:1874 +0x154f goroutine 337340 [IO wait, 2 minutes]: internal/poll.runtime_pollWait(0x7f23413a2920, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc0019f0580?, 0xc002080000?, 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(0xc0019f0580, {0xc002080000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:165 +0x27a net.(*netFD).Read(0xc0019f0580, {0xc002080000?, 0x0?, 0xc00216c500?}) /usr/local/go/src/net/fd_posix.go:55 +0x25 net.(*conn).Read(0xc0025a2628, {0xc002080000?, 0xa7fa1f?, 0xc001280040?}) /usr/local/go/src/net/net.go:189 +0x45 bufio.(*Reader).fill(0xc001afdec0) /usr/local/go/src/bufio/bufio.go:110 +0x103 bufio.(*Reader).Peek(0xc001afdec0, 0x1) /usr/local/go/src/bufio/bufio.go:148 +0x53 github.com/valyala/fasthttp.(*Server).serveConn(0xc000cdb8c8, {0x1423cb8, 0xc0025a2628}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:2202 +0x805 github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc000cd86c0, 0xc00173fd00) /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 337349 [IO wait, 2 minutes]: internal/poll.runtime_pollWait(0x7f2340df5b58, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc001027f00?, 0xc001bfb000?, 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(0xc001027f00, {0xc001bfb000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:165 +0x27a net.(*netFD).Read(0xc001027f00, {0xc001bfb000?, 0x0?, 0xc001d0d100?}) /usr/local/go/src/net/fd_posix.go:55 +0x25 net.(*conn).Read(0xc001308db8, {0xc001bfb000?, 0xa7fa1f?, 0xc00158be40?}) /usr/local/go/src/net/net.go:189 +0x45 bufio.(*Reader).fill(0xc001897380) /usr/local/go/src/bufio/bufio.go:110 +0x103 bufio.(*Reader).Peek(0xc001897380, 0x1) /usr/local/go/src/bufio/bufio.go:148 +0x53 github.com/valyala/fasthttp.(*Server).serveConn(0xc000cdb8c8, {0x1423cb8, 0xc001308db8}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:2202 +0x805 github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc000cd86c0, 0xc001d8f420) /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