nodece opened a new issue, #882: URL: https://github.com/apache/pulsar-client-go/issues/882
See https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042 ``` time="2022-11-02T10:04:16Z" level=info msg="Created consumer" consumerID=4 name=zkjpl subscription=sub01-1667383455 topic="persistent://public/default/sub01-1667383455-RETRY" time="2022-11-02T10:04:16Z" level=info msg="Connected producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" epoch=0 topic="persistent://public/default/sub01-1667383455-RETRY" time="2022-11-02T10:04:16Z" level=info msg="Created producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" producerID=4 producer_name=standalone-0-137 topic="persistent://public/default/sub01-1667383455-RETRY" time="2022-11-02T10:04:16Z" level=info msg="Connected producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" epoch=0 topic="persistent://public/default/sub01-1667383455-DLQ" time="2022-11-02T10:04:16Z" level=info msg="Created producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" producerID=5 producer_name=standalone-0-138 topic="persistent://public/default/sub01-1667383455-DLQ" retry consumed: 300 time="2022-11-02T10:04:17Z" level=info msg="Connected consumer" consumerID=5 name=vqwac subscription=sub01-1667383455 topic="persistent://public/default/sub01-1667383455-DLQ" time="2022-11-02T10:04:17Z" level=info msg="Created consumer" consumerID=5 name=vqwac subscription=sub01-1667383455 topic="persistent://public/default/sub01-1667383455-DLQ" coverage: 48.6% of statements panic: test timed out after 20m0s goroutine 5188 [running]: testing.(*M).startAlarm.func1() /usr/local/go/src/testing/testing.go:2036 +0xbb created by time.goFunc /usr/local/go/src/time/sleep.go:176 +0x48 goroutine 1 [chan receive, 17 minutes]: testing.(*T).Run(0xc00019a340, {0x113f4a1, 0x7}, 0x1196608) /usr/local/go/src/testing/testing.go:1494 +0x789 testing.runTests.func1(0x0?) /usr/local/go/src/testing/testing.go:1846 +0x9a testing.tRunner(0xc00019a340, 0xc000111b68) /usr/local/go/src/testing/testing.go:1446 +0x217 testing.runTests(0xc0001980a0?, {0x17aa560, 0xb1, 0xb1}, {0x40?, 0x7f9467774528?, 0x17f99c0?}) /usr/local/go/src/testing/testing.go:1844 +0x7ed testing.(*M).Run(0xc0001980a0) /usr/local/go/src/testing/testing.go:1726 +0xa85 main.main() _testmain.go:513 +0x3bd goroutine 2572 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc0001b4f20) /pulsar-client-go/pulsar/internal/connection.go:411 +0x67b github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1() /pulsar-client-go/pulsar/internal/connection.go:227 +0xac created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start /pulsar-client-go/pulsar/internal/connection.go:223 +0xb1 goroutine 2499 [IO wait]: internal/poll.runtime_pollWait(0x7f9466fb4d28, 0x72) /usr/local/go/src/runtime/netpoll.go:305 +0x89 internal/poll.(*pollDesc).wait(0xc000214998, 0xc0006dd000?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc000214980, {0xc0006dd000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:167 +0x415 net.(*netFD).Read(0xc000214980, {0xc0006dd000, 0x1000, 0x1000}) /usr/local/go/src/net/fd_posix.go:55 +0x51 net.(*conn).Read(0xc00020cdf8, {0xc0006dd000, 0x1000, 0x1000}) /usr/local/go/src/net/net.go:183 +0xb1 io.ReadAtLeast({0x12fafa0, 0xc00020cdf8}, {0xc0006dd000, 0x1000, 0x1000}, 0x4) /usr/local/go/src/io/io.go:332 +0xde github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc0006ce880, 0x4) /pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc0006ce880) /pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc0006ce880) /pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba goroutine 983 [chan receive, 19 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc0004c4c40) /pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812 goroutine 2452 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc00024fce0, 0xc000409450) /pulsar-client-go/pulsar/internal/connection.go:431 +0xf0 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:389 +0x28a goroutine 2453 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2() /pulsar-client-go/pulsar/internal/connection.go:396 +0xf7 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd goroutine 2451 [IO wait]: internal/poll.runtime_pollWait(0x7f9466fb51d8, 0x72) /usr/local/go/src/runtime/netpoll.go:305 +0x89 internal/poll.(*pollDesc).wait(0xc000214618, 0xc0006ba000?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc000214600, {0xc0006ba000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:167 +0x415 net.(*netFD).Read(0xc000214600, {0xc0006ba000, 0x1000, 0x1000}) /usr/local/go/src/net/fd_posix.go:55 +0x51 net.(*conn).Read(0xc000014e78, {0xc0006ba000, 0x1000, 0x1000}) /usr/local/go/src/net/net.go:183 +0xb1 io.ReadAtLeast({0x12fafa0, 0xc000014e78}, {0xc0006ba000, 0x1000, 0x1000}, 0x4) /usr/local/go/src/io/io.go:332 +0xde github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc000194f40, 0x4) /pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc000194f40) /pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc000194f40) /pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba goroutine 982 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc0004c4c40) /pulsar-client-go/pulsar/consumer_partition.go:933 +0x725 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792 goroutine 2577 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc0001b4f20, 0xc000316820) /pulsar-client-go/pulsar/internal/connection.go:431 +0xf0 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:389 +0x28a goroutine 2204 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc0002c3ce0) /pulsar-client-go/pulsar/internal/connection.go:411 +0x67b github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1() /pulsar-client-go/pulsar/internal/connection.go:227 +0xac created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start /pulsar-client-go/pulsar/internal/connection.go:223 +0xb1 goroutine 984 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2() /pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148 created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop /pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be goroutine 2209 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc0002c3ce0, 0xc000508cd0) /pulsar-client-go/pulsar/internal/connection.go:431 +0xf0 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:389 +0x28a goroutine 2210 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2() /pulsar-client-go/pulsar/internal/connection.go:396 +0xf7 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd goroutine 2208 [IO wait]: internal/poll.runtime_pollWait(0x7f9466fb50e8, 0x72) /usr/local/go/src/runtime/netpoll.go:305 +0x89 internal/poll.(*pollDesc).wait(0xc000107518, 0xc00064c000?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc000107500, {0xc00064c000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:167 +0x415 net.(*netFD).Read(0xc000107500, {0xc00064c000, 0x1000, 0x1000}) /usr/local/go/src/net/fd_posix.go:55 +0x51 net.(*conn).Read(0xc000014bb8, {0xc00064c000, 0x1000, 0x1000}) /usr/local/go/src/net/net.go:183 +0xb1 io.ReadAtLeast({0x12fafa0, 0xc000014bb8}, {0xc00064c000, 0x1000, 0x1000}, 0x4) /usr/local/go/src/io/io.go:332 +0xde github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc000352500, 0x4) /pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc000352500) /pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc000352500) /pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba goroutine 1414 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2() /pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148 created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop /pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be goroutine 1412 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc00012d6c0) /pulsar-client-go/pulsar/consumer_partition.go:933 +0x725 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792 goroutine 1413 [chan receive, 19 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc00012d6c0) /pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812 goroutine 5063 [chan receive, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc0001e5180) /pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812 goroutine [2390](https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042#step:5:2391) [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc00046fa20) /pulsar-client-go/pulsar/internal/connection.go:411 +0x67b github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1() /pulsar-client-go/pulsar/internal/connection.go:227 +0xac created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start /pulsar-client-go/pulsar/internal/connection.go:223 +0xb1 goroutine 2394 [IO wait]: internal/poll.runtime_pollWait(0x7f9466fb4ff8, 0x72) /usr/local/go/src/runtime/netpoll.go:305 +0x89 internal/poll.(*pollDesc).wait(0xc000469c98, 0xc00068a000?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc000469c80, {0xc00068a000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:167 +0x415 net.(*netFD).Read(0xc000469c80, {0xc00068a000, 0x1000, 0x1000}) /usr/local/go/src/net/fd_posix.go:55 +0x51 net.(*conn).Read(0xc00020cb48, {0xc00068a000, 0x1000, 0x1000}) /usr/local/go/src/net/net.go:183 +0xb1 io.ReadAtLeast({0x12fafa0, 0xc00020cb48}, {0xc00068a000, 0x1000, 0x1000}, 0x4) /usr/local/go/src/io/io.go:332 +0xde github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc0000749c0, 0x4) /pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc0000749c0) /pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc0000749c0) /pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba goroutine [2395](https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042#step:5:2396) [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc00046fa20, 0xc00049be00) /pulsar-client-go/pulsar/internal/connection.go:431 +0xf0 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:389 +0x28a goroutine [2396](https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042#step:5:2397) [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2() /pulsar-client-go/pulsar/internal/connection.go:396 +0xf7 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd goroutine 2501 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2() /pulsar-client-go/pulsar/internal/connection.go:396 +0xf7 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd goroutine 2450 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc00024fce0) /pulsar-client-go/pulsar/internal/connection.go:411 +0x67b github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1() /pulsar-client-go/pulsar/internal/connection.go:227 +0xac created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start /pulsar-client-go/pulsar/internal/connection.go:223 +0xb1 goroutine 2497 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc0000a6f20) /pulsar-client-go/pulsar/internal/connection.go:411 +0x67b github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1() /pulsar-client-go/pulsar/internal/connection.go:227 +0xac created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start /pulsar-client-go/pulsar/internal/connection.go:223 +0xb1 goroutine 2500 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc0000a6f20, 0xc0006caa00) /pulsar-client-go/pulsar/internal/connection.go:431 +0xf0 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:389 +0x28a goroutine 2578 [select, 19 minutes]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2() /pulsar-client-go/pulsar/internal/connection.go:396 +0xf7 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd goroutine 2576 [IO wait]: internal/poll.runtime_pollWait(0x7f9466fb4c38, 0x72) /usr/local/go/src/runtime/netpoll.go:305 +0x89 internal/poll.(*pollDesc).wait(0xc000214518, 0xc0005fd000?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc000214500, {0xc0005fd000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:167 +0x415 net.(*netFD).Read(0xc000214500, {0xc0005fd000, 0x1000, 0x1000}) /usr/local/go/src/net/fd_posix.go:55 +0x51 net.(*conn).Read(0xc0000144c8, {0xc0005fd000, 0x1000, 0x1000}) /usr/local/go/src/net/net.go:183 +0xb1 io.ReadAtLeast({0x12fafa0, 0xc0000144c8}, {0xc0005fd000, 0x1000, 0x1000}, 0x4) /usr/local/go/src/io/io.go:332 +0xde github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc000496320, 0x4) /pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc000496320) /pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc000496320) /pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba goroutine 5077 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1() /pulsar-client-go/pulsar/producer_partition.go:437 +0x147 created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop /pulsar-client-go/pulsar/producer_partition.go:435 +0xbe goroutine 5037 [chan receive]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087fb00) /pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8 goroutine 4945 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*consumer).Receive(0xc00037e3c0, {0x1300b70, 0xc00003c078}) /pulsar-client-go/pulsar/consumer_impl.go:433 +0x18a github.com/apache/pulsar-client-go/pulsar.TestRLQ(0x0?) /pulsar-client-go/pulsar/consumer_test.go:1349 +0xd02 testing.tRunner(0xc000946680, 0x1196608) /usr/local/go/src/testing/testing.go:1446 +0x217 created by testing.(*T).Run /usr/local/go/src/testing/testing.go:1493 +0x75e goroutine 5181 [select]: github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery.func1() /pulsar-client-go/pulsar/consumer_impl.go:258 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery /pulsar-client-go/pulsar/consumer_impl.go:255 +0x1d3 goroutine 4980 [select]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087f900) /pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:193 +0x1474 goroutine 5052 [select]: github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery.func1() /pulsar-client-go/pulsar/producer_impl.go:168 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery /pulsar-client-go/pulsar/producer_impl.go:165 +0x1d3 goroutine 5032 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc000746160, 0xc0009b34f0) /pulsar-client-go/pulsar/internal/connection.go:431 +0xf0 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:389 +0x28a goroutine 5071 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556e00) /pulsar-client-go/pulsar/consumer_partition.go:933 +0x725 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792 goroutine 5064 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2() /pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148 created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop /pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be goroutine 4984 [select]: github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery.func1() /pulsar-client-go/pulsar/producer_impl.go:168 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery /pulsar-client-go/pulsar/producer_impl.go:165 +0x1d3 goroutine 5073 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2() /pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148 created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop /pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be goroutine 4987 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*retryRouter).run(0xc000a1e2d0) /pulsar-client-go/pulsar/retry_router.go:84 +0x16d created by github.com/apache/pulsar-client-go/pulsar.newRetryRouter /pulsar-client-go/pulsar/retry_router.go:73 +0x490 goroutine 5031 [IO wait]: internal/poll.runtime_pollWait(0x7f9466fb4b48, 0x72) /usr/local/go/src/runtime/netpoll.go:305 +0x89 internal/poll.(*pollDesc).wait(0xc0008fb418, 0xc0004ff000?, 0x0) /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd internal/poll.(*pollDesc).waitRead(...) /usr/local/go/src/internal/poll/fd_poll_runtime.go:89 internal/poll.(*FD).Read(0xc0008fb400, {0xc0004ff000, 0x1000, 0x1000}) /usr/local/go/src/internal/poll/fd_unix.go:167 +0x415 net.(*netFD).Read(0xc0008fb400, {0xc0004ff000, 0x1000, 0x1000}) /usr/local/go/src/net/fd_posix.go:55 +0x51 net.(*conn).Read(0xc00020c420, {0xc0004ff000, 0x1000, 0x1000}) /usr/local/go/src/net/net.go:183 +0xb1 io.ReadAtLeast({0x12fafa0, 0xc00020c420}, {0xc0004ff000, 0x1000, 0x1000}, 0x4) /usr/local/go/src/io/io.go:332 +0xde github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc00088fac0, 0x4) /pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc00088fac0) /pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4 github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc00088fac0) /pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba goroutine 5078 [select]: github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery.func1() /pulsar-client-go/pulsar/producer_impl.go:168 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery /pulsar-client-go/pulsar/producer_impl.go:165 +0x1d3 goroutine 4985 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1() /pulsar-client-go/pulsar/producer_partition.go:437 +0x147 created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop /pulsar-client-go/pulsar/producer_partition.go:435 +0xbe goroutine 5074 [select]: github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery.func1() /pulsar-client-go/pulsar/consumer_impl.go:258 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery /pulsar-client-go/pulsar/consumer_impl.go:255 +0x1d3 goroutine 5049 [chan receive]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc000120800) /pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8 goroutine 5051 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1() /pulsar-client-go/pulsar/producer_partition.go:437 +0x147 created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop /pulsar-client-go/pulsar/producer_partition.go:435 +0xbe goroutine 5072 [chan receive, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556e00) /pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812 goroutine 5045 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556c40) /pulsar-client-go/pulsar/consumer_partition.go:933 +0x725 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792 goroutine 5068 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2() /pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148 created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop /pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be goroutine 5186 [chan send, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556000) /pulsar-client-go/pulsar/consumer_partition.go:969 +0xd5e created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792 goroutine 5040 [select]: github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc000206e70) /pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker /pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5 goroutine 5047 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2() /pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148 created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop /pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be goroutine 5152 [select]: github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc0006d61c0) /pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker /pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5 goroutine 5060 [select]: github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc000207030) /pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker /pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5 goroutine 5062 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc0001e5180) /pulsar-client-go/pulsar/consumer_partition.go:933 +0x725 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792 goroutine 5066 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556a80) /pulsar-client-go/pulsar/consumer_partition.go:933 +0x725 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792 goroutine 5050 [select]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc000120800) /pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:193 +0x1474 goroutine 5033 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2() /pulsar-client-go/pulsar/internal/connection.go:396 +0xf7 created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run /pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd goroutine 5041 [select]: github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc000206f50) /pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker /pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5 goroutine 5075 [chan receive]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087fc00) /pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8 goroutine 5187 [chan receive, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556000) /pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812 goroutine 5027 [select]: github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc000746160) /pulsar-client-go/pulsar/internal/connection.go:411 +0x67b github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1() /pulsar-client-go/pulsar/internal/connection.go:227 +0xac created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start /pulsar-client-go/pulsar/internal/connection.go:223 +0xb1 goroutine 4979 [chan receive]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087f900) /pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8 goroutine 4981 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1() /pulsar-client-go/pulsar/producer_partition.go:437 +0x147 created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop /pulsar-client-go/pulsar/producer_partition.go:435 +0xbe goroutine 5043 [select]: github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc00017d2d0) /pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker /pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5 goroutine 4986 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*dlqRouter).run(0xc000a1e280) /pulsar-client-go/pulsar/dlq_router.go:89 +0x16e created by github.com/apache/pulsar-client-go/pulsar.newDlqRouter /pulsar-client-go/pulsar/dlq_router.go:56 +0x457 goroutine 5038 [select]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087fb00) /pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:193 +0x1474 goroutine 4982 [chan receive]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087fa00) /pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8 goroutine 5039 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1() /pulsar-client-go/pulsar/producer_partition.go:437 +0x147 created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop /pulsar-client-go/pulsar/producer_partition.go:435 +0xbe goroutine 5069 [select]: github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery.func1() /pulsar-client-go/pulsar/consumer_impl.go:258 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery /pulsar-client-go/pulsar/consumer_impl.go:255 +0x1d3 goroutine 5067 [chan receive, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556a80) /pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812 goroutine 5076 [select]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087fc00) /pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:193 +0x1474 goroutine 5046 [chan receive, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556c40) /pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245 created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer /pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812 goroutine 4983 [select]: github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087fa00) /pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9 created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer /pulsar-client-go/pulsar/producer_partition.go:193 +0x1474 goroutine 5180 [select, 17 minutes]: github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2() /pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148 created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop /pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be FAIL github.com/apache/pulsar-client-go/pulsar 1200.061s ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
