BewareMyPower commented on issue #7726: URL: https://github.com/apache/pulsar/issues/7726#issuecomment-669319484
Here're the outputs of Python client 2.6.0 with broker 2.6.0, using the same code as provided. First start `Producer.py` and `C1.py`, then start `C2.py`. C1: ``` $ python3 C1.py 0 2020-08-05 09:55:18.379 INFO [140237624133440] Client:88 | Subscribing on Topic :test10 2020-08-05 09:55:18.381 INFO [140237624133440] ConnectionPool:85 | Created connection for pulsar://localhost:6650 2020-08-05 09:55:18.383 INFO [140237353412352] ClientConnection:343 | [127.0.0.1:50298 -> 127.0.0.1:6650] Connected to broker 2020-08-05 09:55:18.412 INFO [140237353412352] HandlerBase:53 | [persistent://public/default/test10-partition-0, my-subscription, 0] Getting connection from pool 2020-08-05 09:55:18.413 INFO [140237353412352] HandlerBase:53 | [persistent://public/default/test10-partition-1, my-subscription, 1] Getting connection from pool 2020-08-05 09:55:18.413 INFO [140237353412352] HandlerBase:53 | [persistent://public/default/test10-partition-2, my-subscription, 2] Getting connection from pool 2020-08-05 09:55:18.413 INFO [140237353412352] HandlerBase:53 | [persistent://public/default/test10-partition-3, my-subscription, 3] Getting connection from pool 2020-08-05 09:55:18.582 INFO [140237353412352] ConsumerImpl:199 | [persistent://public/default/test10-partition-3, my-subscription, 3] Created consumer on broker [127.0.0.1:50298 -> 127.0.0.1:6650] 2020-08-05 09:55:18.582 INFO [140237353412352] ConsumerImpl:199 | [persistent://public/default/test10-partition-1, my-subscription, 1] Created consumer on broker [127.0.0.1:50298 -> 127.0.0.1:6650] 2020-08-05 09:55:18.582 INFO [140237353412352] ConsumerImpl:199 | [persistent://public/default/test10-partition-2, my-subscription, 2] Created consumer on broker [127.0.0.1:50298 -> 127.0.0.1:6650] 2020-08-05 09:55:18.582 INFO [140237353412352] ConsumerImpl:199 | [persistent://public/default/test10-partition-0, my-subscription, 0] Created consumer on broker [127.0.0.1:50298 -> 127.0.0.1:6650] 2020-08-05 09:55:18.582 INFO [140237353412352] PartitionedConsumerImpl:302 | Successfully Subscribed to Partitioned Topic - persistent://public/default/test10 with - 4 Partitions. Process p1 Received message 'b'0bbbb'' id='(14,0,3,-1)' partition=persistent://public/default/test10-partition-3 Process p1 Received message 'b'0aaaa'' id='(15,0,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'0dddd'' id='(13,0,0,-1)' partition=persistent://public/default/test10-partition-0 Process p1 Received message 'b'0cccc'' id='(15,1,1,-1)' partition=persistent://public/default/test10-partition-1 # messagess of 2~8... Process p1 Received message 'b'9dddd'' id='(13,9,0,-1)' partition=persistent://public/default/test10-partition-0 Process p1 Received message 'b'9cccc'' id='(15,18,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'9aaaa'' id='(15,19,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'10cccc'' id='(15,20,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'10dddd'' id='(13,10,0,-1)' partition=persistent://public/default/test10-partition-0 Process p1 Received message 'b'10aaaa'' id='(15,21,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'11dddd'' id='(13,11,0,-1)' partition=persistent://public/default/test10-partition-0 Process p1 Received message 'b'11cccc'' id='(15,22,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'11aaaa'' id='(15,23,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'12dddd'' id='(13,12,0,-1)' partition=persistent://public/default/test10-partition-0 Process p1 Received message 'b'12cccc'' id='(15,24,1,-1)' partition=persistent://public/default/test10-partition-1 Process p1 Received message 'b'12aaaa'' id='(15,25,1,-1)' partition=persistent://public/default/test10-partition-1 ``` C2: ``` $ python3 C2.py 0 2020-08-05 09:57:05.193 INFO [139998113343296] ConnectionPool:85 | Created connection for pulsar://localhost:6650 2020-08-05 09:57:05.195 INFO [139997834229504] ClientConnection:343 | [127.0.0.1:50328 -> 127.0.0.1:6650] Connected to broker 2020-08-05 09:57:05.206 INFO [139997834229504] HandlerBase:53 | [persistent://public/default/test10-partition-3, my-subscription, 0] Getting connection from pool 2020-08-05 09:57:05.210 INFO [139997834229504] HandlerBase:53 | [persistent://public/default/test10-partition-2, my-subscription, 1] Getting connection from pool 2020-08-05 09:57:05.215 INFO [139997834229504] ConsumerImpl:199 | [persistent://public/default/test10-partition-3, my-subscription, 0] Created consumer on broker [127.0.0.1:50328 -> 127.0.0.1:6650] 2020-08-05 09:57:05.221 INFO [139997834229504] ConsumerImpl:199 | [persistent://public/default/test10-partition-2, my-subscription, 1] Created consumer on broker [127.0.0.1:50328 -> 127.0.0.1:6650] 2020-08-05 09:57:05.221 INFO [139997834229504] MultiTopicsConsumerImpl:99 | Successfully Subscribed to Topics Process 2 Received message 'b'9bbbb'' id='(14,9,-1,-1)' partition=persistent://public/default/test10-partition-3 Process 2 Received message 'b'10bbbb'' id='(14,10,-1,-1)' partition=persistent://public/default/test10-partition-3 Process 2 Received message 'b'11bbbb'' id='(14,11,-1,-1)' partition=persistent://public/default/test10-partition-3 Process 2 Received message 'b'12bbbb'' id='(14,12,-1,-1)' partition=persistent://public/default/test10-partition-3 ``` Besides, I noticed your log has `AckGroupingTrackerEnabled`, this feature was improved from #6534 but the log level was reduced to debug from #7373 , could you try with latest client or just rollback to 2.6.0? ---------------------------------------------------------------- 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]
