zbentley commented on issue #11823:
URL: https://github.com/apache/pulsar/issues/11823#issuecomment-909266177


   On Python 3.7.10, the bug still occurs, but I get a lot more output, which 
may be useful:
   ```
   DEBUG:foo:Using Binary Lookup
   DEBUG:asyncio:Using selector: KqueueSelector
   INFO:foo:Subscribing on Topic :sometopic
   INFO:foo:Created connection for pulsar://localhost:6650/
   DEBUG:foo:[<none> -> pulsar://localhost:6650/] Connecting to localhost:6650
   DEBUG:foo:[<none> -> pulsar://localhost:6650/] Resolved hostname localhost 
to 127.0.0.1:6650
   INFO:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Connected to broker
   DEBUG:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Handling incoming command: 
CONNECTED
   DEBUG:foo:Connection has max message size setting: 5242880
   DEBUG:foo:Current max message size is: 5242880
   DEBUG:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Handling incoming command: 
PARTITIONED_METADATA_RESPONSE
   DEBUG:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Received partition-metadata 
response from server. req_id: 1
   DEBUG:foo:PartitionMetadataLookup response for 
persistent://public/default/sometopic, lookup-broker-url
   DEBUG:foo:BatchAcknowledgementTracker for 
[persistent://public/default/sometopic, somesub, 0] Constructed 
BatchAcknowledgementTracker
   DEBUG:foo:Created negative ack tracker with delay: 60000 ms - Timer 
interval: 00:00:20
   INFO:foo:[persistent://public/default/sometopic, somesub, 0] Getting 
connection from pool
   DEBUG:foo:Got connection from pool for pulsar://localhost:6650/ use_count: 4 
@ 0x7fdffc820200
   DEBUG:foo:ACK grouping is enabled, grouping time 100ms, grouping max size 
1000
   DEBUG:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Handling incoming command: 
LOOKUP_RESPONSE
   DEBUG:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Received lookup response from 
server. req_id: 2
   DEBUG:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Received lookup response from 
server. req_id: 2 -- broker-url: pulsar://localhost:6650 -- broker-tls-url:  
authoritative: 1 redirect: 1
   DEBUG:foo:Lookup response for persistent://public/default/sometopic, 
lookup-broker-url pulsar://localhost:6650
   DEBUG:foo:Getting connection to broker: pulsar://localhost:6650
   INFO:foo:Created connection for pulsar://localhost:6650
   DEBUG:foo:[<none> -> pulsar://localhost:6650/] Connecting to localhost:6650
   DEBUG:foo:[<none> -> pulsar://localhost:6650/] Resolved hostname localhost 
to 127.0.0.1:6650
   INFO:foo:[127.0.0.1:61247 -> 127.0.0.1:6650] Connected to broker through 
proxy. Logical broker: pulsar://localhost:6650
   DEBUG:foo:[127.0.0.1:61247 -> 127.0.0.1:6650] Handling incoming command: 
CONNECTED
   DEBUG:foo:Connection has max message size setting: 5242880
   DEBUG:foo:Current max message size is: 5242880
   DEBUG:foo:[persistent://public/default/sometopic, somesub, 0] Connected to 
broker: [127.0.0.1:61247 -> 127.0.0.1:6650]
   DEBUG:foo:[127.0.0.1:61247 -> 127.0.0.1:6650] Handling incoming command: 
SUCCESS
   DEBUG:foo:[127.0.0.1:61247 -> 127.0.0.1:6650] Received success response from 
server. req_id: 0
   INFO:foo:[persistent://public/default/sometopic, somesub, 0] Created 
consumer on broker [127.0.0.1:61247 -> 127.0.0.1:6650]
   DEBUG:foo:[persistent://public/default/sometopic, somesub, 0] Send initial 
flow permits: 1000
   DEBUG:foo:[persistent://public/default/sometopic, somesub, 0] Send more 
permits: 1000
   INFO:foo:[persistent://public/default/sometopic, somesub, 0] Closing 
consumer for topic persistent://public/default/sometopic
   DEBUG:foo:[127.0.0.1:61247 -> 127.0.0.1:6650] Handling incoming command: 
SUCCESS
   DEBUG:foo:[127.0.0.1:61247 -> 127.0.0.1:6650] Received success response from 
server. req_id: 1
   INFO:foo:[persistent://public/default/sometopic, somesub, 0] Closed consumer 0
   async returning bar
   StopIteration: bar
   
   The above exception was the direct cause of the following exception:
   
   Traceback (most recent call last):
     File 
"/Users/zac.bentley/.pyenv/versions/3.7.10/lib/python3.7/logging/__init__.py", 
line 1365, in debug
       if self.isEnabledFor(DEBUG):
   SystemError: PyEval_EvalFrameEx returned a result with an error set
   DEBUG:foo:Reference to the HandlerBase is not valid.
   DEBUG:foo:Ignoring timer cancelled event, code[system:89]
   returned: None
   INFO:foo:Closing Pulsar client
   INFO:foo:[127.0.0.1:61247 -> 127.0.0.1:6650] Connection closed
   INFO:foo:[127.0.0.1:61246 -> 127.0.0.1:6650] Connection closed
   ```


-- 
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]


Reply via email to