PC=0x4774e1 m=0 sigcode=0 goroutine 0 [idle]: runtime.futex() /usr/lib/golang/src/runtime/sys_linux_amd64.s:519 +0x21 runtime.futexsleep(0xc000059800, 0x82a2d, 0x2f004fe1) /usr/lib/golang/src/runtime/os_linux.go:44 +0x36 runtime.notesleep(0x1adac50) /usr/lib/golang/src/runtime/lock_futex.go:160 +0x87 runtime.mPark() /usr/lib/golang/src/runtime/proc.go:1441 +0x2a runtime.stopm() /usr/lib/golang/src/runtime/proc.go:2408 +0x78 runtime.findrunnable() /usr/lib/golang/src/runtime/proc.go:2984 +0x865 runtime.schedule() /usr/lib/golang/src/runtime/proc.go:3367 +0x239 runtime.park_m(0xc000102680) /usr/lib/golang/src/runtime/proc.go:3516 +0x14d runtime.mcall() /usr/lib/golang/src/runtime/asm_amd64.s:307 +0x43 goroutine 1 [select, 1610 minutes]: main.startKafkaMessageConsumer({0x7ffebd779da3, 0x6}) /go/src/app/cmd/cloud-connector/kafka_message_consumer.go:139 +0xc3e main.NewRootCommand.func2(0xc0004f8500, {0xf2cb86, 0x2, 0x2}) /go/src/app/cmd/cloud-connector/main.go:39 +0x25 github.com/spf13/cobra.(*Command).execute(0xc0004f8500, {0xc000158fa0, 0x2, 0x2}) /opt/app-root/src/go/pkg/mod/github.com/spf13/cobra@v1.1.3/command.go:856 +0x5f8 github.com/spf13/cobra.(*Command).ExecuteC(0xc0004f8000) /opt/app-root/src/go/pkg/mod/github.com/spf13/cobra@v1.1.3/command.go:960 +0x3ad github.com/spf13/cobra.(*Command).Execute(...) /opt/app-root/src/go/pkg/mod/github.com/spf13/cobra@v1.1.3/command.go:897 main.main() /go/src/app/cmd/cloud-connector/main.go:95 +0x4a goroutine 130 [select, 303 minutes]: github.com/eclipse/paho%2emqtt%2egolang.(*client).startCommsWorkers.func1() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/client.go:567 +0x185 created by github.com/eclipse/paho%2emqtt%2egolang.(*client).startCommsWorkers /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/client.go:564 +0x56f goroutine 111 [select]: github.com/redhatinsights/platform-go-middlewares/logging/cloudwatch.(*Hook).putBatches(0xc0000b0640, 0xc0000443c0, 0xc0006e4a80) /opt/app-root/src/go/pkg/mod/github.com/redhatinsights/platform-go-middlewares@v0.12.0/logging/cloudwatch/hook.go:151 +0xfe created by github.com/redhatinsights/platform-go-middlewares/logging/cloudwatch.NewBatchingHook /opt/app-root/src/go/pkg/mod/github.com/redhatinsights/platform-go-middlewares@v0.12.0/logging/cloudwatch/hook.go:86 +0x23d goroutine 2366 [sync.Cond.Wait, 309 minutes]: sync.runtime_notifyListWait(0xc00014bfd0, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xbc0) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000dfab58) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000dfab40) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 49 [IO wait]: internal/poll.runtime_pollWait(0x7f0ef0ff2848, 0x72) /usr/lib/golang/src/runtime/netpoll.go:303 +0x85 internal/poll.(*pollDesc).wait(0xc0004c0a00, 0xc00077e000, 0x0) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:84 +0x32 internal/poll.(*pollDesc).waitRead(...) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc0004c0a00, {0xc00077e000, 0x1000, 0x1000}) /usr/lib/golang/src/internal/poll/fd_unix.go:167 +0x25a net.(*netFD).Read(0xc0004c0a00, {0xc00077e000, 0xc00044ed00, 0x1}) /usr/lib/golang/src/net/fd_posix.go:56 +0x29 net.(*conn).Read(0xc0004900d0, {0xc00077e000, 0xc0001aee00, 0xc000988a58}) /usr/lib/golang/src/net/net.go:183 +0x45 net/http.(*connReader).Read(0xc000988a50, {0xc00077e000, 0x1000, 0x1000}) /usr/lib/golang/src/net/http/server.go:780 +0x16d bufio.(*Reader).fill(0xc0007ea420) /usr/lib/golang/src/bufio/bufio.go:101 +0x103 bufio.(*Reader).ReadSlice(0xc0007ea420, 0x74) /usr/lib/golang/src/bufio/bufio.go:360 +0x2f bufio.(*Reader).ReadLine(0xc0007ea420) /usr/lib/golang/src/bufio/bufio.go:389 +0x27 net/textproto.(*Reader).readLineSlice(0xc00015aba0) /usr/lib/golang/src/net/textproto/reader.go:57 +0x99 net/textproto.(*Reader).ReadLine(...) /usr/lib/golang/src/net/textproto/reader.go:38 net/http.readRequest(0xc0004900d0) /usr/lib/golang/src/net/http/request.go:1029 +0x79 net/http.(*conn).readRequest(0xc0004ea0a0, {0x1248370, 0xc000732500}) /usr/lib/golang/src/net/http/server.go:966 +0x225 net/http.(*conn).serve(0xc0004ea0a0, {0x1248418, 0xc0004d6870}) /usr/lib/golang/src/net/http/server.go:1856 +0x865 created by net/http.(*Server).Serve /usr/lib/golang/src/net/http/server.go:3034 +0x4e8 goroutine 112 [select, 1610 minutes]: database/sql.(*DB).connectionOpener(0xc00010eea0, {0x1248370, 0xc00014b580}) /usr/lib/golang/src/database/sql/sql.go:1196 +0x93 created by database/sql.OpenDB /usr/lib/golang/src/database/sql/sql.go:794 +0x188 goroutine 113 [select, 1586 minutes]: github.com/segmentio/kafka-go.(*ConsumerGroup).nextGeneration(0xc000222c00, {0x0, 0x0}) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:859 +0x9f8 github.com/segmentio/kafka-go.(*ConsumerGroup).run(0xc000222c00) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:721 +0x50 github.com/segmentio/kafka-go.NewConsumerGroup.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:659 +0x25 created by github.com/segmentio/kafka-go.NewConsumerGroup /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:658 +0x16f goroutine 114 [select, 1586 minutes]: github.com/segmentio/kafka-go.(*ConsumerGroup).Next(0xc000222c00, {0x1248370, 0xc00014a600}) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:700 +0xe5 github.com/segmentio/kafka-go.(*Reader).run(0xc00063a700, 0xc000222c00) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:320 +0x354 created by github.com/segmentio/kafka-go.NewReader /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:742 +0x796 goroutine 138 [chan receive, 303 minutes]: github.com/eclipse/paho%2emqtt%2egolang.(*baseToken).Wait(0x1) /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/token.go:73 +0x1f github.com/RedHatInsights/cloud-connector/internal/mqtt.sendMessage({0x1259b28, 0xc0001246c0}, 0x1, {0xc0007633d0, 0x24}, 0xc0004e22e0, {0xc000a48b00, 0x3f}, 0x1, {0xdc16c0, ...}) /go/src/app/internal/mqtt/utils.go:66 +0x37d github.com/RedHatInsights/cloud-connector/internal/mqtt.SendReconnectMessageToClient({0x1259b28, 0xc0001246c0}, 0xc000752db8, 0xc000982520, 0x24, {0xc0007633d0, 0x24}, 0xc000459810) /go/src/app/internal/mqtt/utils.go:30 +0x2f8 github.com/RedHatInsights/cloud-connector/internal/cloud_connector.handleOnlineMessage(0x84efa6, {0x1259b28, 0xc0001246c0}, {0xc0007633d0, 0x24}, {{0xc00003ed98, 0x11}, {0xc00013d980, 0x24}, 0x1, ...}, ...) /go/src/app/internal/cloud_connector/message_handlers.go:125 +0x2e6 github.com/RedHatInsights/cloud-connector/internal/cloud_connector.handleConnectionStatusMessage(0xc0007535a0, {0x1259b28, 0xc0001246c0}, {0xc0007633d0, 0x24}, {{0xc00003ed98, 0x11}, {0xc00013d980, 0x24}, 0x1, ...}, ...) /go/src/app/internal/cloud_connector/message_handlers.go:94 +0x1f0 github.com/RedHatInsights/cloud-connector/internal/cloud_connector.HandleControlMessage.func1({0x1259b28, 0xc0001246c0}, {0xc0007633d0, 0x24}, {0xc000ac4f00, 0x65ff01}) /go/src/app/internal/cloud_connector/message_handlers.go:67 +0x78e main.handleMessage.func1(0xc0007c7320) /go/src/app/cmd/cloud-connector/kafka_message_consumer.go:217 +0x455 main.consumeMqttMessagesFromKafka(0x0, 0xc00015bc20, {0x1248370, 0xc000516980}, 0x0) /go/src/app/cmd/cloud-connector/kafka_message_consumer.go:238 +0x2e2 created by main.startKafkaMessageConsumer /go/src/app/cmd/cloud-connector/kafka_message_consumer.go:126 +0xaa9 goroutine 63 [select]: github.com/eclipse/paho%2emqtt%2egolang.keepalive(0xc0001246c0, {0x7f0ec8089320, 0xc00015b800}) /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/ping.go:44 +0x1f1 created by github.com/eclipse/paho%2emqtt%2egolang.(*client).startCommsWorkers /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/client.go:542 +0x325 goroutine 3418 [sync.Cond.Wait, 398 minutes]: sync.runtime_notifyListWait(0xc000ea2410, 0x5) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x1b0cb60) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000143278) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000143260) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 64 [chan receive, 1610 minutes]: github.com/eclipse/paho%2emqtt%2egolang.(*router).matchAndDispatch.func2() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/router.go:170 +0xbc created by github.com/eclipse/paho%2emqtt%2egolang.(*router).matchAndDispatch /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/router.go:169 +0x26f goroutine 131 [IO wait]: internal/poll.runtime_pollWait(0x7f0ef0ff2668, 0x72) /usr/lib/golang/src/runtime/netpoll.go:303 +0x85 internal/poll.(*pollDesc).wait(0xc000804700, 0xc000294000, 0x0) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:84 +0x32 internal/poll.(*pollDesc).waitRead(...) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc000804700, {0xc000294000, 0x1ab1, 0x1ab1}) /usr/lib/golang/src/internal/poll/fd_unix.go:167 +0x25a net.(*netFD).Read(0xc000804700, {0xc000294000, 0xc000294005, 0x15}) /usr/lib/golang/src/net/fd_posix.go:56 +0x29 net.(*conn).Read(0xc00014c048, {0xc000294000, 0x6, 0xc0001887b8}) /usr/lib/golang/src/net/net.go:183 +0x45 crypto/tls.(*atLeastReader).Read(0xc0008ec210, {0xc000294000, 0x0, 0x41474d}) /usr/lib/golang/src/crypto/tls/conn.go:778 +0x3d bytes.(*Buffer).ReadFrom(0xc000240278, {0x12330a0, 0xc0008ec210}) /usr/lib/golang/src/bytes/buffer.go:204 +0x98 crypto/tls.(*Conn).readFromUntil(0xc000240000, {0x1234ae0, 0xc00014c048}, 0x1ab1) /usr/lib/golang/src/crypto/tls/conn.go:800 +0xe5 crypto/tls.(*Conn).readRecordOrCCS(0xc000240000, 0x0) /usr/lib/golang/src/crypto/tls/conn.go:607 +0x112 crypto/tls.(*Conn).readRecord(...) /usr/lib/golang/src/crypto/tls/conn.go:575 crypto/tls.(*Conn).Read(0xc000240000, {0xc0001c5000, 0x1000, 0x7f0ec9f87fff}) /usr/lib/golang/src/crypto/tls/conn.go:1278 +0x16f bufio.(*Reader).fill(0xc0005fcd20) /usr/lib/golang/src/bufio/bufio.go:101 +0x103 bufio.(*Reader).Peek(0xc0005fcd20, 0x2) /usr/lib/golang/src/bufio/bufio.go:139 +0x5d github.com/gorilla/websocket.(*Conn).read(0xc0001cc160, 0x0) /opt/app-root/src/go/pkg/mod/github.com/gorilla/websocket@v1.4.2/conn.go:370 +0x2c github.com/gorilla/websocket.(*Conn).advanceFrame(0xc0001cc160) /opt/app-root/src/go/pkg/mod/github.com/gorilla/websocket@v1.4.2/conn.go:798 +0x7b github.com/gorilla/websocket.(*Conn).NextReader(0xc0001cc160) /opt/app-root/src/go/pkg/mod/github.com/gorilla/websocket@v1.4.2/conn.go:980 +0xc5 github.com/eclipse/paho%2emqtt%2egolang.(*websocketConnector).Read(0xc00015b800, {0xc0009ffabe, 0x1, 0x1}) /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/websocket.go:102 +0xf5 io.ReadAtLeast({0x7f0ec8089340, 0xc00015b800}, {0xc0009ffabe, 0x1, 0x1}, 0x1) /usr/lib/golang/src/io/io.go:328 +0x9a io.ReadFull(...) /usr/lib/golang/src/io/io.go:347 github.com/eclipse/paho.mqtt.golang/packets.ReadPacket({0x7f0ec8089340, 0xc00015b800}) /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/packets/packets.go:115 +0x65 github.com/eclipse/paho%2emqtt%2egolang.startIncoming.func1() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:119 +0xea created by github.com/eclipse/paho%2emqtt%2egolang.startIncoming /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:117 +0x152 goroutine 132 [select]: github.com/eclipse/paho%2emqtt%2egolang.startIncomingComms.func1() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:170 +0x193 created by github.com/eclipse/paho%2emqtt%2egolang.startIncomingComms /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:159 +0x1ba goroutine 133 [select, 303 minutes]: github.com/eclipse/paho%2emqtt%2egolang.startOutgoingComms.func1() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:272 +0x1f0 created by github.com/eclipse/paho%2emqtt%2egolang.startOutgoingComms /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:259 +0x25a goroutine 134 [chan receive, 1610 minutes]: github.com/eclipse/paho%2emqtt%2egolang.startComms.func1() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:401 +0x71 created by github.com/eclipse/paho%2emqtt%2egolang.startComms /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:400 +0x212 goroutine 135 [chan receive, 1610 minutes]: github.com/eclipse/paho%2emqtt%2egolang.startComms.func2() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:424 +0x74 created by github.com/eclipse/paho%2emqtt%2egolang.startComms /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:423 +0x285 goroutine 136 [semacquire, 1610 minutes]: sync.runtime_Semacquire(0x0) /usr/lib/golang/src/runtime/sema.go:56 +0x25 sync.(*WaitGroup).Wait(0x0) /usr/lib/golang/src/sync/waitgroup.go:130 +0x71 github.com/eclipse/paho%2emqtt%2egolang.startComms.func3() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:432 +0x2a created by github.com/eclipse/paho%2emqtt%2egolang.startComms /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/net.go:431 +0x2de goroutine 137 [select, 1610 minutes]: github.com/eclipse/paho%2emqtt%2egolang.(*client).startCommsWorkers.func2() /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/client.go:602 +0x105 created by github.com/eclipse/paho%2emqtt%2egolang.(*client).startCommsWorkers /opt/app-root/src/go/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.3.5/client.go:597 +0x6e5 goroutine 142 [IO wait]: internal/poll.runtime_pollWait(0x7f0ef0ff2758, 0x72) /usr/lib/golang/src/runtime/netpoll.go:303 +0x85 internal/poll.(*pollDesc).wait(0xc000804980, 0xc000048000, 0x0) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:84 +0x32 internal/poll.(*pollDesc).waitRead(...) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Accept(0xc000804980) /usr/lib/golang/src/internal/poll/fd_unix.go:402 +0x22c net.(*netFD).accept(0xc000804980) /usr/lib/golang/src/net/fd_unix.go:173 +0x35 net.(*TCPListener).accept(0xc0005ccf18) /usr/lib/golang/src/net/tcpsock_posix.go:140 +0x28 net.(*TCPListener).Accept(0xc0005ccf18) /usr/lib/golang/src/net/tcpsock.go:262 +0x3d net/http.(*Server).Serve(0xc0006b82a0, {0x1241080, 0xc0005ccf18}) /usr/lib/golang/src/net/http/server.go:3002 +0x394 net/http.(*Server).ListenAndServe(0xc0006b82a0) /usr/lib/golang/src/net/http/server.go:2931 +0x7d github.com/RedHatInsights/cloud-connector/internal/platform/utils.StartHTTPServer.func1() /go/src/app/internal/platform/utils/utils.go:22 +0xf3 created by github.com/RedHatInsights/cloud-connector/internal/platform/utils.StartHTTPServer /go/src/app/internal/platform/utils/utils.go:20 +0x128 goroutine 144 [syscall, 1610 minutes]: os/signal.signal_recv() /usr/lib/golang/src/runtime/sigqueue.go:169 +0x98 os/signal.loop() /usr/lib/golang/src/os/signal/signal_unix.go:24 +0x19 created by os/signal.Notify.func1.1 /usr/lib/golang/src/os/signal/signal.go:151 +0x2c goroutine 3938 [sync.Cond.Wait, 389 minutes]: sync.runtime_notifyListWait(0xc0004af210, 0x5) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xadec42) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0005fc9d8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0005fc9c0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 194 [IO wait]: internal/poll.runtime_pollWait(0x7f0ef0ff2488, 0x72) /usr/lib/golang/src/runtime/netpoll.go:303 +0x85 internal/poll.(*pollDesc).wait(0xc0007dc000, 0xc00055d000, 0x0) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:84 +0x32 internal/poll.(*pollDesc).waitRead(...) /usr/lib/golang/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc0007dc000, {0xc00055d000, 0x1000, 0x1000}) /usr/lib/golang/src/internal/poll/fd_unix.go:167 +0x25a net.(*netFD).Read(0xc0007dc000, {0xc00055d000, 0xc00044ed00, 0x1}) /usr/lib/golang/src/net/fd_posix.go:56 +0x29 net.(*conn).Read(0xc000490000, {0xc00055d000, 0xc0001aee00, 0xc000988128}) /usr/lib/golang/src/net/net.go:183 +0x45 net/http.(*connReader).Read(0xc000988120, {0xc00055d000, 0x1000, 0x1000}) /usr/lib/golang/src/net/http/server.go:780 +0x16d bufio.(*Reader).fill(0xc0007ea0c0) /usr/lib/golang/src/bufio/bufio.go:101 +0x103 bufio.(*Reader).ReadSlice(0xc0007ea0c0, 0x74) /usr/lib/golang/src/bufio/bufio.go:360 +0x2f bufio.(*Reader).ReadLine(0xc0007ea0c0) /usr/lib/golang/src/bufio/bufio.go:389 +0x27 net/textproto.(*Reader).readLineSlice(0xc0005bdce0) /usr/lib/golang/src/net/textproto/reader.go:57 +0x99 net/textproto.(*Reader).ReadLine(...) /usr/lib/golang/src/net/textproto/reader.go:38 net/http.readRequest(0xc000490000) /usr/lib/golang/src/net/http/request.go:1029 +0x79 net/http.(*conn).readRequest(0xc0006d4000, {0x1248370, 0xc000516140}) /usr/lib/golang/src/net/http/server.go:966 +0x225 net/http.(*conn).serve(0xc0006d4000, {0x1248418, 0xc0004d6870}) /usr/lib/golang/src/net/http/server.go:1856 +0x865 created by net/http.(*Server).Serve /usr/lib/golang/src/net/http/server.go:3034 +0x4e8 goroutine 1381 [sync.Cond.Wait, 317 minutes]: sync.runtime_notifyListWait(0xc000517810, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0007eb098) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0007eb080) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 2313 [sync.Cond.Wait, 417 minutes]: sync.runtime_notifyListWait(0xc000748310, 0x5) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xadec42) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0007eac18) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0007eac00) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1877 [select, 303 minutes]: github.com/segmentio/kafka-go.(*Reader).commitLoopImmediate(0xc00063a700, {0x1249090, 0xc0004c0380}, 0xc000874730) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:213 +0x1dc github.com/segmentio/kafka-go.(*Reader).commitLoop(0xc000f0c660, {0x1249090, 0xc0004c0380}, 0x0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:296 +0x18b github.com/segmentio/kafka-go.(*Reader).run.func3({0x1249090, 0xc0004c0380}) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:350 +0x34 github.com/segmentio/kafka-go.(*Generation).Start.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:396 +0x31 created by github.com/segmentio/kafka-go.(*Generation).Start /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:395 +0x16f goroutine 3985 [sync.Cond.Wait, 389 minutes]: sync.runtime_notifyListWait(0xc000ea26d0, 0x5) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000143518) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000143500) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1364 [sync.Cond.Wait, 365 minutes]: sync.runtime_notifyListWait(0xc000f06d50, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x1b0cb60) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000f0d2d8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f0d2c0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 3385 [sync.Cond.Wait, 398 minutes]: sync.runtime_notifyListWait(0xc000f06250, 0x5) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xadec42) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0007ea7f8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0007ea7e0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1875 [select]: github.com/segmentio/kafka-go.(*Generation).heartbeatLoop.func1({0x1249090, 0xc0004c0380}) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:477 +0x1ba github.com/segmentio/kafka-go.(*Generation).Start.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:396 +0x31 created by github.com/segmentio/kafka-go.(*Generation).Start /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:395 +0x16f goroutine 1338 [sync.Cond.Wait, 365 minutes]: sync.runtime_notifyListWait(0xc000f06150, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xadec42) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000f0c318) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000f0c300) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1285 [sync.Cond.Wait, 368 minutes]: sync.runtime_notifyListWait(0xc000f062d0, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xcc0) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000961e18) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000961e00) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 3537 [sync.Cond.Wait, 395 minutes]: sync.runtime_notifyListWait(0xc000517f90, 0x5) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x1b0cb60) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc0004819f8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc0004819e0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1152 [sync.Cond.Wait, 350 minutes]: sync.runtime_notifyListWait(0xc000ea2e50, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xc0008006c0) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000481698) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000481680) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1281 [select]: github.com/segmentio/kafka-go.(*connPool).discover(0xc000c2c300, {0x1248370, 0xc000ea2a80}, 0xc000801680) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/transport.go:620 +0x4b0 created by github.com/segmentio/kafka-go.(*Transport).grabPool /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/transport.go:254 +0x5a7 goroutine 2355 [sync.Cond.Wait, 309 minutes]: sync.runtime_notifyListWait(0xc00014b310, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000afded8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000afdec0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1337 [chan receive]: github.com/segmentio/kafka-go.(*conn).run(0xc000f8e780, 0xc000ea2d80, 0x0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/transport.go:1246 +0xb3 created by github.com/segmentio/kafka-go.(*connGroup).connect /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/transport.go:1224 +0xd14 goroutine 1322 [sync.Cond.Wait, 365 minutes]: sync.runtime_notifyListWait(0xc00014aa50, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000eb62b8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000eb62a0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1325 [sync.Cond.Wait, 359 minutes]: sync.runtime_notifyListWait(0xc00014b410, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000eb72d8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000eb72c0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 2502 [sync.Cond.Wait, 303 minutes]: sync.runtime_notifyListWait(0xc000ea2f90, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000961038) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000961020) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1327 [sync.Cond.Wait, 352 minutes]: sync.runtime_notifyListWait(0xc000032310, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x1b0cb60) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000142a38) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000142a20) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1878 [select, 1586 minutes]: github.com/segmentio/kafka-go.(*Reader).run.func4({0x1249090, 0xc0004c0380}) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:354 +0x97 github.com/segmentio/kafka-go.(*Generation).Start.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:396 +0x31 created by github.com/segmentio/kafka-go.(*Generation).Start /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/consumergroup.go:395 +0x16f goroutine 4432 [sync.Cond.Wait, 389 minutes]: sync.runtime_notifyListWait(0xc00014aa10, 0x5) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000dfa4f8) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000dfa4e0) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 2250 [sync.Cond.Wait, 309 minutes]: sync.runtime_notifyListWait(0xc000ea20d0, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0xadec42) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000afd398) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000afd380) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 goroutine 1876 [select, 96 minutes]: github.com/segmentio/kafka-go.(*reader).sendMessage(0xc0007dc600, {0x1248370, 0xc000ea2140}, {{0xc00013c750, 0x2c}, 0x0, 0x1a05e1, 0x1a05e2, {0xc0001bba70, 0x24, ...}, ...}, ...) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:1529 +0x10f github.com/segmentio/kafka-go.(*reader).read(0xc00019fed8, {0x1248370, 0xc000ea2140}, 0x1a05e1, 0xc000392960) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:1501 +0x4f0 github.com/segmentio/kafka-go.(*reader).run(0xc00019fed8, {0x1248370, 0xc000ea2140}, 0x1a05e1) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:1310 +0x5e5 github.com/segmentio/kafka-go.(*Reader).start.func1({0x1248370, 0xc000ea2140}, {{0xc000042bd0, 0x1234a60}, 0x877fd0}, 0x735a26, 0xc00058b020) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:1211 +0x1be created by github.com/segmentio/kafka-go.(*Reader).start /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/reader.go:1191 +0x148 goroutine 2214 [sync.Cond.Wait, 309 minutes]: sync.runtime_notifyListWait(0xc000733390, 0x6) /usr/lib/golang/src/runtime/sema.go:513 +0x13d sync.(*Cond).Wait(0x654605) /usr/lib/golang/src/sync/cond.go:56 +0x8c github.com/segmentio/kafka-go.(*batchQueue).Get(0xc000eae558) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:918 +0x9c github.com/segmentio/kafka-go.(*partitionWriter).writeBatches(0xc000eae540) /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:978 +0x3b github.com/segmentio/kafka-go.(*Writer).spawn.func1() /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:532 +0x64 created by github.com/segmentio/kafka-go.(*Writer).spawn /opt/app-root/src/go/pkg/mod/github.com/segmentio/kafka-go@v0.4.27/writer.go:530 +0x92 rax 0xca rbx 0x0 rcx 0x4774e3 rdx 0x0 rdi 0x1adac50 rsi 0x80 rbp 0x7ffebd778228 rsp 0x7ffebd7781e0 r8 0x0 r9 0x0 r10 0x0 r11 0x286 r12 0x818 r13 0x11 r14 0x1ada3a0 r15 0x0 rip 0x4774e1 rflags 0x286 cs 0x33 fs 0x0 gs 0x0