goroutine 34397326 [running]: runtime/pprof.writeGoroutineStacks({0x7fa29c626b68, 0xc001b1bb60}) /usr/local/go/src/runtime/pprof/pprof.go:761 +0x6a runtime/pprof.writeGoroutine({0x7fa29c626b68?, 0xc001b1bb60?}, 0xc001b1bc20?) /usr/local/go/src/runtime/pprof/pprof.go:750 +0x25 runtime/pprof.(*Profile).WriteTo(0x2482340?, {0x7fa29c626b68?, 0xc001b1bb60?}, 0xc?) /usr/local/go/src/runtime/pprof/pprof.go:374 +0x14b net/http/pprof.handler.ServeHTTP({0x11a3c04, 0x9}, {0x13f07e0, 0xc001b1bb60}, 0xc0090ed040) /usr/local/go/src/net/http/pprof/pprof.go:272 +0x52f net/http.HandlerFunc.ServeHTTP(0xc0081f99b0?, {0x13f07e0?, 0xc001b1bb60?}, 0xc0081f99b0?) /usr/local/go/src/net/http/server.go:2220 +0x29 dsdrive/pkg/http.registerProfiler.NewFastHTTPHandlerFunc.NewFastHTTPHandler.func20(0xc0071b5808) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/fasthttpadaptor/adaptor.go:63 +0x151 dsdrive/pkg/http.registerProfiler.func9(0x1029820?) /build/pkg/http/profiler.go:89 +0x1e github.com/gofiber/fiber/v2.(*App).next(0xc000192a08, 0xc0011f6c08) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/router.go:145 +0x1be github.com/gofiber/fiber/v2.(*App).handler(0xc000192a08, 0x4b0d2f?) /go/pkg/mod/github.com/gofiber/fiber/v2@v2.52.6/router.go:172 +0x69 github.com/valyala/fasthttp.(*Server).serveConn(0xc0003fe488, {0x13f8c78, 0xc000146af8}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:2394 +0x11b1 github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc00031e120, 0xc005e702a0) /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 95 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:196 +0x194 goroutine 1 [chan receive, 90712 minutes]: dsdrive/pkg/app.(*App).waitForCompletion(0xc00031e240) /build/pkg/app/app.go:173 +0x7c dsdrive/pkg/app.(*App).run(0xc00031e240, 0x0?) /build/pkg/app/app.go:100 +0x125 dsdrive/pkg/app.Run(0xc0003b5f00) /build/pkg/app/app.go:68 +0xc6 dsdrive/pkg/cmd.Run(0x12b1c88) /build/pkg/cmd/cmd.go:50 +0x14d main.main() /build/cmd/app/main.go:16 +0x1f goroutine 25 [select, 90712 minutes]: database/sql.(*DB).connectionOpener(0xc0000b04e0, {0x13f31c0, 0xc000166320}) /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 47 [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 96 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:60 +0xc5 goroutine 96 [IO wait]: internal/poll.runtime_pollWait(0x7fa29c790d68, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc0000f6680?, 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(0xc0000f6680) /usr/local/go/src/internal/poll/fd_unix.go:620 +0x295 net.(*netFD).accept(0xc0000f6680) /usr/local/go/src/net/fd_unix.go:172 +0x29 net.(*TCPListener).accept(0xc0002f2900) /usr/local/go/src/net/tcpsock_posix.go:159 +0x1e net.(*TCPListener).Accept(0xc0002f2900) /usr/local/go/src/net/tcpsock.go:372 +0x30 github.com/valyala/fasthttp.acceptConn(0xc0003fe6c8, {0x13f0cd0, 0xc0002f2900}, 0xc000216d50) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1929 +0x55 github.com/valyala/fasthttp.(*Server).Serve(0xc0003fe6c8, {0x13f0cd0, 0xc0002f2900}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1823 +0x4d2 github.com/gofiber/fiber/v2.(*App).Listener(0xc000192f08, {0x13f0cd0, 0xc0002f2900}) /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:151 +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 91 [select, 1434 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc001536700, {0x13f31c0, 0xc00030e8c0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x13f30e0?, 0x24d3c00?}) /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: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 6104 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc0014ef290, 0x60) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc001209eb8?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0015d1ab8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0015d1aa0) /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 5959 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 23 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc000136110, 0x66) /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(0xc00007eaf8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00007eae0) /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 49 [select]: github.com/segmentio/kafka-go.(*connPool).discover(0xc0002441c0, {0x13f31c0, 0xc00051a0f0}, 0xc0001400e0) /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 93 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc000136680, {0x13f31c0, 0xc00051ac80}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x13f30e0?, 0x24d3c00?}) /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 95 [IO wait]: internal/poll.runtime_pollWait(0x7fa29c7910b0, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc000239080?, 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(0xc000239080) /usr/local/go/src/internal/poll/fd_unix.go:620 +0x295 net.(*netFD).accept(0xc000239080) /usr/local/go/src/net/fd_unix.go:172 +0x29 net.(*TCPListener).accept(0xc0015367c0) /usr/local/go/src/net/tcpsock_posix.go:159 +0x1e net.(*TCPListener).Accept(0xc0015367c0) /usr/local/go/src/net/tcpsock.go:372 +0x30 github.com/valyala/fasthttp.acceptConn(0xc0003fe488, {0x13f0cd0, 0xc0015367c0}, 0xc000352dc8) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1929 +0x55 github.com/valyala/fasthttp.(*Server).Serve(0xc0003fe488, {0x13f0cd0, 0xc0015367c0}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:1823 +0x4d2 github.com/gofiber/fiber/v2.(*App).Listener(0xc000192a08, {0x13f0cd0, 0xc0015367c0}) /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 94 [select, 51 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc00037da40, {0x13f31c0, 0xc00051acd0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x13f30e0?, 0x24d3c00?}) /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 92 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc001536740, {0x13f31c0, 0xc00030e730}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x13f30e0?, 0x24d3c00?}) /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.5() /build/internal/app/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 90 [select, 3 minutes]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc0015366c0, {0x13f31c0, 0xc00030e820}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x13f30e0?, 0x24d3c00?}) /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: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 68 [select, 3 minutes]: github.com/patrickmn/go-cache.(*janitor).Run(0xc000023020, 0xc000136180) /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 [select]: github.com/patrickmn/go-cache.(*janitor).Run(0xc00012c5c0, 0xc000136600) /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 133 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0000fb6c0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 117 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 31473232 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0071eb040, 0xc00783c720) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 31473238 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 72 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*TCPDialer).tcpAddrsClean(0x249a540) /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 89 [select]: dsdrive/pkg/job.waitForTimerSignal(...) /build/pkg/job/job.go:80 dsdrive/pkg/job.(*Job).run(0xc001536680, {0x13f31c0, 0xc00030e7d0}) /build/pkg/job/job.go:69 +0x1bc dsdrive/pkg/job.(*Job).StartContext(0x0?, {0x13f30e0?, 0x24d3c00?}) /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: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 132 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc000160500, 0xc00028b6e0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 117 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 129 [select, 90712 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 130 [select, 90712 minutes]: dsdrive/pkg/app.(*App).notifyCompletion(0xc00031e240) /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 48 [syscall, 90712 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 143 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc000160280, 0xc00029c3c0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 117 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 114 [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 95 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:60 +0xc5 goroutine 144 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0017581a0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 117 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 59 [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 117 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/header.go:2366 +0x1f goroutine 9287 [sync.Cond.Wait, 11076 minutes]: sync.runtime_notifyListWait(0xc00144a250, 0x4b) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x1000000000000?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001742af8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001742ae0) /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 9211 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 5424 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc0010fee50, 0x67) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc000fbdf18?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001ec8078) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001ec8060) /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 5451 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 25724 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc000e39540, 0xc001722cf0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 25706 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 5506 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc00180c3d0, 0x5e) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x202130e01?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0012d8c78) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0012d8c60) /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 5451 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 6106 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc0014ef3d0, 0x5a) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc0002c56e8?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0015d1bd8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0015d1bc0) /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 5917 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 33802 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc00024dba0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 33817 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 31561766 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0011d6000) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 31561756 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 12568889 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0013597c0, 0xc002263ce0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 12568901 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 5512 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc00180c710, 0x46) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000000e705a7?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0012d8df8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0012d8de0) /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 5451 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 6269118 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc001dc9a00) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 6269114 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 5454 [sync.Cond.Wait, 1057 minutes]: sync.runtime_notifyListWait(0xc0000b3c10, 0x61) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc00051ab01?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00007f458) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00007f440) /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 5448 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 5550 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc000137e50, 0x52) /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(0xc000119a58) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000119a40) /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 5525 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 6269117 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc000313180, 0xc00029dad0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 6269114 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 5478 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc0002f3450, 0x63) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000001d855a7?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001e8a378) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001e8a360) /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 5451 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 18905621 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0016bc640, 0xc00026d5f0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 18905583 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 5418 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc0010feb50, 0x58) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000001d83da7?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00051fc38) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00051fc20) /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 5448 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 9547 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc001590090, 0x50) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x24af940?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0017164f8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0017164e0) /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 9349 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 25725 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc001125040) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 25706 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 6119 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc0014efad0, 0x5a) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc000217f18?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00166a018) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00166a000) /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 5917 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 12631525 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc00117fe00, 0xc0021e0ab0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 12631506 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 5519 [sync.Cond.Wait, 1065 minutes]: sync.runtime_notifyListWait(0xc00180ca50, 0x50) /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(0xc0012d90f8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0012d90e0) /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 5448 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 18843847 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc001211a40, 0xc00216c420) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 18843824 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 5569 [sync.Cond.Wait, 1063 minutes]: sync.runtime_notifyListWait(0xc00160d790, 0x61) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000000cdbf18?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc001ec9458) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc001ec9440) /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 5525 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 34397350 [chan receive]: github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc000150000, 0xc007db4080) /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 96 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:196 +0x194 goroutine 9625 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc00160d5d0, 0x58) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0xc0012d0f01?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0016a3698) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0016a3680) /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 9349 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 9658 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc001628290, 0x5c) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x24af901?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00204c978) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00204c960) /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 9349 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 5558 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc00180cd90, 0x54) /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(0xc0012d9278) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0012d9260) /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 5448 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 5539 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc001330050, 0x58) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000000069f01?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000119098) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000119080) /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 5448 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 6515 [sync.Cond.Wait, 1047 minutes]: sync.runtime_notifyListWait(0xc00180c750, 0x54) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000001d855a7?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00162a258) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00162a240) /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 6084 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 12631526 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc001695860) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 12631506 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 6331595 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0018b4680) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 6331633 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 6011 [sync.Cond.Wait, 1065 minutes]: sync.runtime_notifyListWait(0xc00037d450, 0x5c) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x2000001d855a7?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0013dae58) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0013dae40) /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 5959 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 6057 [sync.Cond.Wait, 1059 minutes]: sync.runtime_notifyListWait(0xc00037dbd0, 0x65) /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(0xc0013db5d8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0013db5c0) /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 5959 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 6024 [sync.Cond.Wait, 1061 minutes]: sync.runtime_notifyListWait(0xc00180c210, 0x53) /usr/local/go/src/runtime/sema.go:587 +0x159 sync.(*Cond).Wait(0x66c480b648c5c601?) /usr/local/go/src/sync/cond.go:71 +0x85 github.com/segmentio/kafka-go.(*batchQueue).Get(0xc00007f1b8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00007f1a0) /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 5959 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 18843848 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc001694820) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 18843824 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 34027734 [chan receive]: github.com/segmentio/kafka-go.(*conn).run(0xc002207720, 0xc001823d80, 0xc00102ebd0) /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 34027723 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/transport.go:1235 +0xd31 goroutine 33801 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0001af680, 0xc0002d58f0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 33817 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 31561765 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0012f2a00, 0xc00223e7e0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 31561756 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 9827 [sync.Cond.Wait, 1065 minutes]: sync.runtime_notifyListWait(0xc001629150, 0x5f) /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(0xc00204d1b8) /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:953 +0x85 github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc00204d1a0) /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 9349 /go/pkg/mod/github.com/segmentio/kafka-go@v0.4.47/writer.go:545 +0x7c goroutine 18905622 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0018b4ea0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 18905583 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 25112816 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc00112c3c0, 0xc00562a840) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 25112814 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 27906 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc001695040) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 27880 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 34397152 [IO wait]: internal/poll.runtime_pollWait(0x7fa29c6ed4b0, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc001412b80?, 0xc009252000?, 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(0xc001412b80, {0xc009252000, 0x2000, 0x2000}) /usr/local/go/src/internal/poll/fd_unix.go:165 +0x27a net.(*netFD).Read(0xc001412b80, {0xc009252000?, 0x1000000800692?, 0xc0097f59a0?}) /usr/local/go/src/net/fd_posix.go:55 +0x25 net.(*conn).Read(0xc000146888, {0xc009252000?, 0xc0079d26e0?, 0xc009252005?}) /usr/local/go/src/net/net.go:189 +0x45 crypto/tls.(*atLeastReader).Read(0xc0091a8f78, {0xc009252000?, 0x0?, 0xc0091a8f78?}) /usr/local/go/src/crypto/tls/conn.go:809 +0x3b bytes.(*Buffer).ReadFrom(0xc008085438, {0x13e7ce0, 0xc0091a8f78}) /usr/local/go/src/bytes/buffer.go:211 +0x98 crypto/tls.(*Conn).readFromUntil(0xc008085188, {0x13e5fa0, 0xc000146888}, 0xc0097f5a10?) /usr/local/go/src/crypto/tls/conn.go:831 +0xde crypto/tls.(*Conn).readRecordOrCCS(0xc008085188, 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(0xc008085188, {0xc009211000, 0x1000, 0xc001597880?}) /usr/local/go/src/crypto/tls/conn.go:1385 +0x150 bufio.(*Reader).Read(0xc007d472c0, {0xc00152cac0, 0x9, 0x247e040?}) /usr/local/go/src/bufio/bufio.go:241 +0x197 io.ReadAtLeast({0x13e4c80, 0xc007d472c0}, {0xc00152cac0, 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({0xc00152cac0, 0x9, 0xc001977110?}, {0x13e4c80?, 0xc007d472c0?}) /usr/local/go/src/net/http/h2_bundle.go:1642 +0x65 net/http.(*http2Framer).ReadFrame(0xc00152ca80) /usr/local/go/src/net/http/h2_bundle.go:1909 +0x85 net/http.(*http2clientConnReadLoop).run(0xc0097f5fa8) /usr/local/go/src/net/http/h2_bundle.go:9496 +0xda net/http.(*http2ClientConn).readLoop(0xc008784900) /usr/local/go/src/net/http/h2_bundle.go:9392 +0x7c created by net/http.(*http2Transport).newClientConn in goroutine 34397151 /usr/local/go/src/net/http/h2_bundle.go:8006 +0xd1b goroutine 31473265 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0021e8b60) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 31473238 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 6331594 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0013bb040, 0xc00319ff20) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 6331633 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 25190018 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc001103e00, 0xc00028bbc0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 25190009 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 12568890 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc001257d40) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 12568901 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 27905 [sleep]: time.Sleep(0x3b9aca00) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*Client).mCleaner(0xc0017a0000, 0xc0017bc150) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:616 +0x6e created by github.com/valyala/fasthttp.(*Client).Do in goroutine 27880 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:584 +0x686 goroutine 25190019 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc0018b5d40) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 25190009 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319 goroutine 34396988 [IO wait]: internal/poll.runtime_pollWait(0x7fa29c6edb40, 0x72) /usr/local/go/src/runtime/netpoll.go:351 +0x85 internal/poll.(*pollDesc).wait(0xc00131c880?, 0xc0014b8000?, 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(0xc00131c880, {0xc0014b8000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:165 +0x27a net.(*netFD).Read(0xc00131c880, {0xc0014b8000?, 0x0?, 0xc00134e400?}) /usr/local/go/src/net/fd_posix.go:55 +0x25 net.(*conn).Read(0xc000148e50, {0xc0014b8000?, 0xa7f75f?, 0xc00144a080?}) /usr/local/go/src/net/net.go:189 +0x45 bufio.(*Reader).fill(0xc007d465a0) /usr/local/go/src/bufio/bufio.go:110 +0x103 bufio.(*Reader).Peek(0xc007d465a0, 0x1) /usr/local/go/src/bufio/bufio.go:148 +0x53 github.com/valyala/fasthttp.(*Server).serveConn(0xc0003fe488, {0x13f8c78, 0xc000148e50}) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/server.go:2202 +0x805 github.com/valyala/fasthttp.(*workerPool).workerFunc(0xc00031e120, 0xc00173d420) /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 95 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/workerpool.go:196 +0x194 goroutine 25112833 [sleep]: time.Sleep(0x2540be400) /usr/local/go/src/runtime/time.go:300 +0xf2 github.com/valyala/fasthttp.(*HostClient).connsCleaner(0xc001695ba0) /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1743 +0x4f created by github.com/valyala/fasthttp.(*HostClient).AcquireConn in goroutine 25112814 /go/pkg/mod/github.com/valyala/fasthttp@v1.60.0/client.go:1635 +0x319