merlimat commented on issue #7324: URL: https://github.com/apache/pulsar/issues/7324#issuecomment-650398389
It seems to be working for me. Using your code above with Python3.8 and pulsar-client==2.6.0. ``` $ python3 a.py 2020-06-26 13:56:55.615 INFO [0x70000321d000] ConnectionPool:85 | Created connection for pulsar://localhost:6650 2020-06-26 13:56:55.617 INFO [0x7000032a0000] ClientConnection:335 | [127.0.0.1:65389 -> 127.0.0.1:6650] Connected to broker 2020-06-26 13:56:55.621 INFO [0x7000032a0000] AckGroupingTrackerEnabled:53 | ACK grouping is enabled, grouping time 100ms, grouping max size 1000 2020-06-26 13:56:55.621 INFO [0x7000032a0000] HandlerBase:53 | [persistent://public/default/my-topic-1, reader-06cf831e5f, 0] Getting connection from pool 2020-06-26 13:56:55.622 INFO [0x7000032a0000] ConsumerImpl:199 | [persistent://public/default/my-topic-1, reader-06cf831e5f, 0] Created consumer on broker [127.0.0.1:65389 -> 127.0.0.1:6650] ``` ---------------------------------------------------------------- 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: [email protected]
