dsmlily opened a new issue #173: lookupTopicResponse cause crash URL: https://github.com/apache/pulsar-client-go/issues/173 time="2020-01-15T03:53:19+08:00" level=debug msg="Wait until connection is ready. State: Initializing" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=info msg="Connecting to broker" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=info msg="TCP connection established" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 31" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Wait until connection is ready. State: TCPConnected" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=info msg="Connection is ready" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 48" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:PARTITIONED_METADATA_RESPONSE partitionMetadataResponse:<partitions:32 request_id:1 response:Success > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:PARTITIONED_METADATA_RESPONSE partitionMetadataResponse:<partitions:32 request_id:1 response:Success > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:10 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:9 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:2 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:10 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 50" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.72:6650 pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:6 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:4 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:5 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:11 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:7 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:23 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:9 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got topic lookup response: &{type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:10 authoritative:false proxy_through_service_url:false > %!s(*internal.connection=&{{0 0} 0xc000428e80 3 30000000000 0xc0004d2180 0xc0004d2180 0xc0000100f0 {0 0} 0xc000423bc0 0xc000423c40 {0 0} {13798929116483089276 19553189 0x11ac480} 0xc000474230 0xc000474280 0xc000552000 0 0xc000513440 0xc0005134a0 0xc0004ae2a0 0xc000513500 map[2:0xc00056a20time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:7 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr=" 10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:23 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr= "10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:9 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr ="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got topic lookup response: &{type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:10 authoritative:false proxy_through_service_url:false > %!s(*internal.con nection=&{{0 0} 0xc000428e80 3 30000000000 0xc0004d2180 0xc0004d2180 0xc0000100f0 {0 0} 0xc000423bc0 0xc000423c40 {0 0} {13798929116483089276 19553189 0x11ac480} 0xc000474230 0xc000474280 0xc000552000 0 0xc000513440 0xc0005134a0 0xc0004ae2a0 0xc000513500 map[2:0xc00056a20 0 4:0xc00056a2e0 5:0xc00056a3a0 6:0xc00045e560 7:0xc00056a480 9:0xc00045e620 11:0xc00045e7a0 12:0xc00056a5e0 13:0xc00045e880 14:0xc00056af60 15:0xc00056a6e0 16:0xc00056a7a0 17:0xc00056a860 19:0xc00045e9c0 20:0xc00045ea80 21:0xc00045eb40 22:0xc00056a980 23:0xc00045ebe0 24:0xc00056aa60 25:0xc00045ecc0 26:0xc00056ab40 27:0xc00056ac40 28:0xc00056ad00 29:0xc00056adc0 30:0xc00045ee00 31:0xc00056aea0 32:0xc00056b040 33:0xc00056b120] map[] {{0 0} 0 0 0 0} map[] <nil> 0x11ca520})}" topic=1/signal/rpc_queue-partition-19 time="2020-01-15T03:53:19+08:00" level=debug msg="Follow redirect to broker. 0xc0004d9430 / <nil> - Use proxy: 0xc00046bb49" topic=1/signal/rpc_queue-partition-19 time="2020-01-15T03:53:19+08:00" level=debug msg="Wait until connection is ready. State: Initializing" remote_addr="pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=info msg="Connecting to broker" remote_addr="pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got topic lookup response: &{type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:9 authoritative:false proxy_through_service_url:false > %!s(*internal.connection=&{{0 0} 0xc000428e80 3 30000000000 0xc0004d2180 0xc0004d2180 0xc0000100f0 {0 0} 0xc000423bc0 0xc000423c40 {0 0} {13798929116483301737 19765711 0x11ac480} 0xc000474230 0xc000474280 0xc000552000 0 0xc000513440 0xc0005134a0 0xc0004ae2a0 0xc000513500 map[2:0xc00056a200 4:0xc00056a2e0 5:0xc00056a3a0 6:0xc00045e560 7:0xc00056a480 11:0xc00045e7a0 12:0xc00056a5e0 13:0xc00045e880 14:0xc00056af60 15:0xc00056a6e0 16:0xc00056a7a0 17:0xc00056a860 19:0xc00045e9c0 20:0xc00045ea80 21:0xc00045eb40 22:0xc00056a980 23:0xc00045ebe0 24:0xc00056aa60 25:0xc00045ecc0 26:0xc00056ab40 27:0xc00056ac40 28:0xc00056ad00 29:0xc00056adc0 30:0xc00045ee00 31:0xc00056aea0 32:0xc00056b040 33:0xc00056b120] map[] {{0 0} 0 0 0 0} map[] <nil> 0x11ca520})}" topic=1/signal/rpc_queue-partition-5 time="2020-01-15T03:53:19+08:00" level=debug msg="Follow redirect to broker. 0xc0004d94b0 / <nil> - Use proxy: 0xc00046bdd9" topic=1/signal/rpc_queue-partition-5 time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.69:6650 pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Wait until connection is ready. State: Initializing" remote_addr="pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:2 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:21 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:12 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:30 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=info msg="TCP connection established" local_addr="10.109.2.158:58194" remote_addr="pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got topic lookup response: &{type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:2 authoritative:false proxy_through_service_url:false > %!s(*internal.connection=&{{0 0} 0xc000428e80 3 30000000000 0xc0004d2180 0xc0004d2180 0xc0000100f0 {1 0} 0xc000423bc0 0xc000423c40 {0 0} {13798929116483483289 19947201 0x11ac480} 0xc000474230 0xc000474280 0xc000552000 0 0xc000513440 0xc0005134a0 0xc0004ae2a0 0xc000513500 map[3:0xc00056b1c0 4:0xc00056a2e0 5:0xc00056a3a0 6:0xc00045e560 7:0xc00056a480 11:0xc00045e7a0 12:0xc00056a5e0 13:0xc00045e880 14:0xc00056af60 15:0xc00056a6e0 16:0xc00056a7a0 17:0xc00056a860 18:0xc00045f000 19:0xc00045e9c0 20:0xc00045ea80 21:0xc00045eb40 22:0xc00056a980 23:0xc00045ebe0 24:0xc00056aa60 25:0xc00045ecc0 26:0xc00056ab40 27:0xc00056ac40 28:0xc00056ad00 29:0xc00056adc0 30:0xc00045ee00 31:0xc00056aea0 32:0xc00056b040 33:0xc00056b120] map[] {{0 0} 0 0 0 0} map[] <nil> 0x11ca520})}" topic=1/signal/rpc_queue-partition-1 time="2020-01-15T03:53:19+08:00" level=debug msg="Follow redirect to broker. 0xc0004d9530 / <nil> - Use proxy: 0xc0006ee069" topic=1/signal/rpc_queue-partition-1 time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.69:6650 pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 31" local_addr="10.109.2.158:58194" remote_addr="pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:25 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:6 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:4 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Follow redirect to broker. 0xc0004d9530 / <nil> - Use proxy: 0xc0006ee069" topic=1/signal/rpc_queue-partition-1 time="2020-01-15T03:53:19+08:00" level=debug msg="Found connection in cache:pulsar://10.109.2.69:6650 pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 31" local_addr="10.109.2.158:58194" remote_addr="pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:25 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr= "10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:6 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr ="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:4 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr ="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 31" local_addr="10.109.2.158:58194" remote_addr="pulsar://10.109.2.69:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Got command! type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:25 authoritative:false proxy_through_service_url:false > with payload size: 0" local_addr= "10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:6 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr ="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:4 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr ="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Write data: 49" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:5 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" time="2020-01-15T03:53:19+08:00" level=debug msg="Received command: type:LOOKUP_RESPONSE lookupTopicResponse:<brokerServiceUrl:\"pulsar://10.109.2.69:6650\" response:Redirect request_id:11 authoritative:false proxy_through_service_url:false > -- payload: <nil>" local_addr="10.109.2.158:46870" remote_addr="pulsar://10.109.2.72:6650" panic: reflect: call of reflect.Value.Type on zero Value goroutine 42 [running]: reflect.Value.Type(0x0, 0x0, 0x0, 0xcfbd01, 0xaba620) /root/.gvm/gos/go1.13.1/src/reflect/value.go:1877 +0x166 internal/fmtsort.compare(0x0, 0x0, 0x0, 0xaba620, 0xc0007032f8, 0xab, 0x1) /root/.gvm/gos/go1.13.1/src/internal/fmtsort/sort.go:76 +0x5a internal/fmtsort.(*SortedMap).Less(0xc000655020, 0x19, 0x18, 0x0) /root/.gvm/gos/go1.13.1/src/internal/fmtsort/sort.go:27 +0x87 sort.insertionSort(0xcec240, 0xc000655020, 0x14, 0x1a) /root/.gvm/gos/go1.13.1/src/sort/sort.go:27 +0xc4 sort.stable(0xcec240, 0xc000655020, 0x1a) /root/.gvm/gos/go1.13.1/src/sort/sort.go:368 +0x86 sort.Stable(0xcec240, 0xc000655020) /root/.gvm/gos/go1.13.1/src/sort/sort.go:357 +0x53 internal/fmtsort.Sort(0xae73a0, 0xc0000ba420, 0x1b5, 0x1b2) /root/.gvm/gos/go1.13.1/src/internal/fmtsort/sort.go:67 +0x2ab fmt.(*pp).printValue(0xc0000d4000, 0xae73a0, 0xc0000ba420, 0x1b5, 0x76, 0x2) /root/.gvm/gos/go1.13.1/src/fmt/print.go:773 +0xd18 fmt.(*pp).printValue(0xc0000d4000, 0xbdd8a0, 0xc0000ba360, 0x199, 0xc000000076, 0x1) /root/.gvm/gos/go1.13.1/src/fmt/print.go:810 +0x1b45 fmt.(*pp).printValue(0xc0000d4000, 0xbde140, 0xc0000ba360, 0x16, 0x76, 0x0) /root/.gvm/gos/go1.13.1/src/fmt/print.go:880 +0x194a fmt.(*pp).badVerb(0xc0000d4000, 0xc000000073) /root/.gvm/gos/go1.13.1/src/fmt/print.go:343 +0x4f6 fmt.(*pp).fmtPointer(0xc0000d4000, 0xbde140, 0xc0000ba360, 0x16, 0x73) /root/.gvm/gos/go1.13.1/src/fmt/print.go:536 +0xc0 fmt.(*pp).printValue(0xc0000d4000, 0xbde140, 0xc0000ba360, 0x16, 0x73, 0x2) /root/.gvm/gos/go1.13.1/src/fmt/print.go:886 +0xc94 fmt.(*pp).printValue(0xc0000d4000, 0xb32580, 0xc00045f820, 0x199, 0xc000000073, 0x1) /root/.gvm/gos/go1.13.1/src/fmt/print.go:810 +0x1b45 fmt.(*pp).printValue(0xc0000d4000, 0xa94300, 0xc00045f820, 0x16, 0xc000000073, 0x0) /root/.gvm/gos/go1.13.1/src/fmt/print.go:880 +0x194a fmt.(*pp).printArg(0xc0000d4000, 0xa94300, 0xc00045f820, 0x73) /root/.gvm/gos/go1.13.1/src/fmt/print.go:716 +0x2b4 fmt.(*pp).doPrintf(0xc0000d4000, 0xbfc818, 0x1d, 0xc000723668, 0x1, 0x1) /root/.gvm/gos/go1.13.1/src/fmt/print.go:1030 +0x15b fmt.Sprintf(0xbfc818, 0x1d, 0xc0005c1668, 0x1, 0x1, 0x0, 0x0) /root/.gvm/gos/go1.13.1/src/fmt/print.go:219 +0x66 github.com/sirupsen/logrus.(*Entry).Logf(0xc000732070, 0x5, 0xbfc818, 0x1d, 0xc0005c1668, 0x1, 0x1) /data/code/Multi-SiteHighAvailabilitySignalServer/thirdparty/src/github.com/sirupsen/logrus/entry.go:314 +0x7a github.com/sirupsen/logrus.(*Entry).Debugf(...) /data/code/Multi-SiteHighAvailabilitySignalServer/thirdparty/src/github.com/sirupsen/logrus/entry.go:323 github.com/apache/pulsar-client-go/pulsar/internal.(*lookupService).Lookup(0xc000423b60, 0xc000012fe0, 0x1e, 0x203000, 0x203000, 0x203000) /data/code/Multi-SiteHighAvailabilitySignalServer/thirdparty/src/github.com/apache/pulsar-client-go/pulsar/internal/lookup_service.go:90 +0x285 github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).grabConn(0xc00049e600, 0xc00049e600, 0xdf8475800) /data/code/Multi-SiteHighAvailabilitySignalServer/thirdparty/src/github.com/apache/pulsar-client-go/pulsar/consumer_partition.go:590 +0x61 github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer(0xcf55c0, 0xc0000d61c0, 0xc000428d80, 0xc0000b8240, 0xc000513320, 0x0, 0x0, 0x0) /data/code/Multi-SiteHighAvailabilitySignalServer/thirdparty/src/github.com/apache/pulsar-client-go/pulsar/consumer_partition.go:142 +0x516 github.com/apache/pulsar-client-go/pulsar.internalTopicSubscribe.func1(0xc000580d50, 0xc00042afa0, 0xc0001434e0, 0x400, 0x0, 0xc0000d61c0, 0xc000428d80, 0xc000513320, 0xc000586840, 0x3, ...) /data/code/Multi-SiteHighAvailabilitySignalServer/thirdparty/src/github.com/apache/pulsar-client-go/pulsar/consumer_impl.go:173 +0x1c4 created by github.com/apache/pulsar-client-go/pulsar.internalTopicSubscribe /data/code/Multi-SiteHighAvailabilitySignalServer/thirdparty/src/github.com/apache/pulsar-client-go/pulsar/consumer_impl.go:149 +0x41a (END)
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
