BewareMyPower commented on issue #949: URL: https://github.com/apache/pulsar-client-go/issues/949#issuecomment-1456295702
**Updated** In my [latest code](https://github.com/BewareMyPower/pulsar-client-go/tree/bewaremypower/ack-list), I changed the grouping config: ```bash ./perf consume --profile \ --enable-batch-index-ack \ --ack-group-max-ms 100 \ --ack-group-max-size 10000000 \ my-topic ``` And now, the consumer can catch up the producer in my local env, though the produce rate is only about 20 MB/s. ``` INFO[22:53:30.112] Stats - Publish rate: 195124.5 msg/s - 156.3 Mbps - Latency ms: 50% 2.4 -95% 5.0 - 99% 19.5 - 99.9% 19.5 - max 19.5 INFO[22:53:40.113] Stats - Publish rate: 190353.9 msg/s - 152.5 Mbps - Latency ms: 50% 2.4 -95% 5.3 - 99% 20.8 - 99.9% 20.8 - max 20.8 INFO[22:53:50.112] Stats - Publish rate: 178765.6 msg/s - 143.2 Mbps - Latency ms: 50% 2.6 -95% 6.3 - 99% 19.0 - 99.9% 19.0 - max 19.0 INFO[22:54:00.113] Stats - Publish rate: 163200.0 msg/s - 130.7 Mbps - Latency ms: 50% 2.7 -95% 6.7 - 99% 21.9 - 99.9% 21.9 - max 21.9 INFO[22:54:10.112] Stats - Publish rate: 147459.4 msg/s - 118.1 Mbps - Latency ms: 50% 2.9 -95% 7.6 - 99% 25.2 - 99.9% 25.2 - max 25.2 INFO[22:54:20.112] Stats - Publish rate: 157722.7 msg/s - 126.3 Mbps - Latency ms: 50% 2.7 -95% 7.6 - 99% 21.7 - 99.9% 21.7 - max 21.7 INFO[22:54:30.112] Stats - Publish rate: 159618.6 msg/s - 127.9 Mbps - Latency ms: 50% 2.9 -95% 6.7 - 99% 20.4 - 99.9% 20.4 - max 20.4 ``` ``` INFO[22:53:27.683] Stats - Consume rate: 148102.4 msg/s - 118.6 Mbps INFO[22:53:37.683] Stats - Consume rate: 192455.4 msg/s - 154.2 Mbps INFO[22:53:47.684] Stats - Consume rate: 176964.8 msg/s - 141.8 Mbps INFO[22:53:57.683] Stats - Consume rate: 169696.7 msg/s - 135.9 Mbps INFO[22:54:07.683] Stats - Consume rate: 156973.3 msg/s - 125.7 Mbps INFO[22:54:17.683] Stats - Consume rate: 148775.7 msg/s - 119.2 Mbps INFO[22:54:27.683] Stats - Consume rate: 160154.4 msg/s - 128.3 Mbps INFO[22:54:37.683] Stats - Consume rate: 141378.7 msg/s - 113.3 Mbps ``` I won't push the PR at the moment because I think there is something wrong with the ACK grouping tracker implementation. Ideally, we should not configure such a large value of `MaxSize`. -- 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]
