Skip to content

Instantly share code, notes, and snippets.

@gonzalop

gonzalop/aa_intro_mosquitto_v2.1rc2.md

Last active January 23, 2026 17:28
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save gonzalop/904177a8b4ee9156fe87fcb503b222fa to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save gonzalop/904177a8b4ee9156fe87fcb503b222fa to your computer and use it in GitHub Desktop.
Download ZIP
Raw
aa_intro_mosquitto_v2.1rc2.md

Below is the analysis and the actual output of running the throughput test in https://github.com/gonzalop/mq, using examples/throughput/multiple_different_args.sh against a local mosquitto MQTT 2.1rc2 server running on a container with host networking.

Note that Paho v3 lacks features and checks present in v5 clients, so it's not really comparing apples to apples, but it's a good reference.

The analysis is what Gemini thought of the output from both the client side and the server side perspectives.

Raw
client_comparison_report.md

MQTT Client Library Comparison Report

Executive Summary

This report compares the performance of three MQTT client libraries:

  1. mq (Internal/New library)
  2. paho_v3 (Eclipse Paho MQTT Go v3)
  3. paho_v5 (Eclipse Paho MQTT Go v5)

The tests were conducted against a local MQTT server (tcp://127.0.0.1:1883) using varying message sizes, concurrency levels (workers), and Quality of Service (QoS) levels.

Key Findings:

  • Performance: mq significantly outperforms both Paho versions in terms of message rate and throughput across almost all scenarios. In high-concurrency scenarios (e.g., 50 workers), mq can be 2-3x faster than Paho.
  • Memory Efficiency: mq consistently demonstrates lower memory allocation (TotalAlloc) and fewer Garbage Collection (GC) cycles compared to paho_v5 and often paho_v3. This suggests a more optimized memory management strategy.
  • Reliability: paho_v5 exhibited stability issues, particularly with large message sizes (10KB) or high concurrency, frequently dropping messages or timing out ("Subscriber idle"). mq showed high reliability, with only isolated incidents of instability which it seemed to recover from. paho_v3 was stable but generally slower.

Detailed Performance Analysis

1. Throughput & Message Rate (QoS 0)

Scenario: Low Concurrency (1 Worker)

Message Size Client Rate (msgs/sec) E2E Rate (msgs/sec) Throughput (MB/sec)
20 B paho_v3 277,801 238,668 4.55
paho_v5 360,046 N/A (Timeout) N/A
mq 509,224 350,725 6.69
128 B paho_v3 253,440 240,336 29.34
paho_v5 335,261 199,343 24.33
mq 281,042 236,913 28.92
1 KB paho_v3 197,300 N/A N/A
paho_v5 N/A N/A N/A
mq 257,570 239,298 233.69
10 KB paho_v3 73,107 73,019 713.08
paho_v5 159,778 N/A N/A
mq 67,401 66,052 645.04

Note: Missing data indicates test failures or timeouts.

Scenario: High Concurrency (50 Workers)

Message Size Client Rate (msgs/sec) E2E Rate (msgs/sec) Throughput (MB/sec)
20 B paho_v3 280,365 264,665 5.05
paho_v5 212,003 191,547 3.65
mq 627,745 530,769 10.12
128 B paho_v3 314,750 273,967 33.44
paho_v5 326,283 145,949 (Loss) 17.82
mq 251,378 215,428 26.30
1 KB paho_v3 173,076 166,412 162.51
paho_v5 89,738 48,468 (Loss) 47.33
mq 209,584 196,230 191.63
10 KB paho_v3 57,444 57,395 560.50
paho_v5 N/A N/A N/A
mq 63,101 61,850 604.01

2. Throughput & Message Rate (QoS 1)

Scenario: High Concurrency (50 Workers)

Message Size Client Rate (msgs/sec) E2E Rate (msgs/sec) Throughput (MB/sec)
20 B paho_v3 84,120 84,097 1.60
paho_v5 56,626 56,609 1.08
mq 129,816 129,762 2.48
128 B paho_v3 82,057 82,028 10.01
paho_v5 61,702 61,689 7.53
mq 189,894 189,775 23.17
1 KB paho_v3 77,245 77,219 75.41
paho_v5 60,093 60,075 58.67
mq 140,752 140,685 137.39
10 KB paho_v3 52,634 50,695 495.08
paho_v5 33,362 19,722 (Loss) 192.60
mq 36,259 36,252 354.03

3. Throughput & Message Rate (QoS 2)

Scenario: High Concurrency (50 Workers)

Message Size Client Rate (msgs/sec) E2E Rate (msgs/sec) Throughput (MB/sec)
20 B paho_v3 42,606 42,587 0.81
paho_v5 29,403 29,391 0.56
mq 61,110 61,064 1.16
128 B paho_v3 42,313 42,295 5.16
paho_v5 35,153 35,136 4.29
mq 77,744 77,671 9.48
1 KB paho_v3 40,894 40,877 39.92
paho_v5 32,825 32,817 32.05
mq 58,261 58,225 56.86
10 KB paho_v3 30,855 30,845 301.22
paho_v5 16,824 13,632 (Loss) 133.13
mq 33,870 33,855 330.62

Memory Usage & Efficiency

The following comparison highlights the efficiency of mq over paho_v5 and paho_v3. Lower TotalAlloc and NumGC indicate better memory optimization and less garbage collection pressure.

Test Case: 50 Workers, 10KB Payload, QoS 0

  • mq: TotalAlloc = 4,136 MiB, NumGC = 1,927
  • paho_v3: TotalAlloc = 6,370 MiB, NumGC = 2,763
  • paho_v5: (Failed)

Test Case: 50 Workers, 1KB Payload, QoS 1

  • mq: TotalAlloc = 67 MiB, NumGC = 23
  • paho_v3: TotalAlloc = 208 MiB, NumGC = 81
  • paho_v5: TotalAlloc = 600 MiB, NumGC = 462

Test Case: 50 Workers, 20B Payload, QoS 1

  • mq: TotalAlloc = 28 MiB, NumGC = 10
  • paho_v3: TotalAlloc = 84 MiB, NumGC = 31
  • paho_v5: TotalAlloc = 397 MiB, NumGC = 330

Conclusion: mq allocates significantly less memory (often 3-10x less than paho_v5) and triggers far fewer GC cycles. This efficiency likely contributes to its higher throughput and stability.

Reliability Observations

  • Paho v5: Showed significant instability. It frequently timed out ("Subscriber idle") and failed to process all messages, especially with larger payloads (10KB) or high concurrency.
  • Paho v3: Generally stable and processed all messages, though slower and more memory-intensive than mq.
  • mq: Highly reliable. It successfully processed messages in almost all scenarios. In one instance (10KB, 1 Worker, QoS 0), it initially idled but appeared to retry or succeed in a subsequent run, suggesting potentially better recovery or transient environment issues rather than systemic failure.
Raw
server_performance_report.md

Mosquitto v2.1rc2 Broker Performance Analysis (Server Perspective)

This report analyzes how the Mosquitto v2.1rc2 broker responded to the stress tests, focusing on its limits, scaling behavior, and resource management.

1. Broker Saturation Points

Based on the test results, we can identify the server's peak capacity on the current hardware/OS configuration:

  • Peak Ingress Rate: ~1,291,000 messages/sec (Achieved with mq, 4 workers, 20B payload, QoS 0).
  • Peak Bandwidth: ~839 MB/sec (Achieved with mq, 4 workers, 10KB payload, QoS 0).
  • Packet Handling Limit: The broker successfully processed (End-to-End) up to ~757,000 msgs/sec without loss. Beyond this rate (or when subscribers were slower, as seen with paho_v5), the broker's outgoing buffers filled, leading to message drops to protect server memory.

2. QoS Overhead Analysis

The broker's processing capacity is heavily impacted by the delivery guarantees required. QoS 1 and 2 introduce state tracking and multiple handshakes per message.

Metric QoS 0 (Best Effort) QoS 1 (At Least Once) QoS 2 (Exactly Once)
Max E2E Rate ~757,000 msgs/s ~190,000 msgs/s ~96,000 msgs/s
Broker Efficiency 100% (Baseline) ~25% of QoS 0 ~12.6% of QoS 0

Insight: QoS 2 performance has improved significantly compared to previous versions (previously ~11%), but it still requires roughly 8x the computational effort of QoS 0.

3. Concurrency & Scaling

Mosquitto v2.1rc2 demonstrates a shift in its optimal concurrency sweet spot:

  • Positive Scaling: Increasing from 1 to 4 workers allowed the broker to process 116% more messages per second (from 350k to 757k msgs/s E2E).
  • Negative Scaling: Increasing from 4 to 20 workers resulted in a 33% performance drop (from 757k down to 506k msgs/s). This suggests that for this version/configuration, context switching or lock contention becomes a bottleneck earlier than observed in previous reports (where 20 workers was the peak).
  • Saturation: Performance remained relatively flat or slightly improved between 20 and 50 workers, indicating the broker had hit a hard architectural limit around 500k-600k msgs/s for high-concurrency scenarios.

4. Broker Stress Responses

The tests revealed how the broker handles "uncooperative" or extremely fast clients:

  • Subscriber Lag & Drops: When paho_v5 published at high rates (e.g., 276k msgs/s with 1KB payload), the subscriber failed to keep up. The broker correctly identified the stalled connection ("Subscriber idle") and dropped messages to prevent resource exhaustion.
  • Robustness with Fast Clients: The mq client, despite pushing the highest ingress rates (1.29M msgs/s), generally maintained a synchronized subscriber, allowing the broker to deliver max throughput without drops in most QoS 0 scenarios. This highlights that "broker stress" is often a symptom of client asymmetry.

5. Key Server Stressors (Ranked)

  1. Message Frequency: High-frequency small packets (1.29M+ msgs/s) tax the CPU most heavily, as shown by the sharp drop in throughput when packet size decreases.
  2. QoS Handshaking: QoS 1/2 remains the primary constraint on throughput, reducing capacity by 75-88%.
  3. Concurrency Overhead: The shift in peak performance to 4 workers indicates high sensitivity to thread/connection contention in this version.

Conclusion

Mosquitto v2.1rc2 shows impressive performance gains, with peak ingress rates exceeding 1.29 million messages/sec—a ~26% improvement over the previous report's 1.02M benchmark. QoS 2 performance also saw a significant boost (~60% increase). However, the "sweet spot" for concurrency has tightened to around 4 workers, with scaling penalties appearing sooner. The broker remains highly robust, protecting itself effectively against slow subscribers by dropping messages when necessary.

Raw
test_output.txt
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 20 -workers 1 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 719.939091ms
Rate: 277801.28 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 837.981449ms
End-to-End Rate: 238668.77 msgs/sec
Throughput: 4.55 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 281 MiB
Sys = 17 MiB
NumGC = 92
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 555.484051ms
Rate: 360046.34 msgs/sec
⏳ Waiting for subscriber to finish or drain...
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 10240 -workers 1 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (10240 bytes each) with QoS 0...
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (10240 bytes each) with QoS 0...
mq
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 107304/200000 in 1.684080694s
End-to-End Rate: 63716.66 msgs/sec
Throughput: 1.22 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 1759 MiB
Sys = 18 MiB
NumGC = 935
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 392.753892ms
Rate: 509224.74 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 570.245834ms
End-to-End Rate: 350725.93 msgs/sec
Throughput: 6.69 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 107 MiB
Sys = 17 MiB
NumGC = 38
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 128 -workers 1 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 789.139958ms
Rate: 253440.47 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 832.168308ms
End-to-End Rate: 240336.00 msgs/sec
Throughput: 29.34 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 353 MiB
Sys = 17 MiB
NumGC = 117
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 596.549118ms
Rate: 335261.58 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 143999/200000 in 722.365421ms
End-to-End Rate: 199343.71 msgs/sec
Throughput: 24.33 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 864 MiB
Sys = 17 MiB
NumGC = 459
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 711.636252ms
Rate: 281042.46 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 844.189371ms
End-to-End Rate: 236913.67 msgs/sec
Throughput: 28.92 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 127 MiB
Sys = 17 MiB
NumGC = 46
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 1024 -workers 1 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 1.013684293s
Rate: 197300.09 msgs/sec
⏳ Waiting for subscriber to finish or drain...
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (1024 bytes each) with QoS 0...
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 776.487934ms
Rate: 257570.00 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 835.775709ms
End-to-End Rate: 239298.65 msgs/sec
Throughput: 233.69 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 300 MiB
Sys = 17 MiB
NumGC = 105
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 10240 -workers 1 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 2.73568181s
Rate: 73107.92 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 2.739001116s
End-to-End Rate: 73019.32 msgs/sec
Throughput: 713.08 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 6370 MiB
Sys = 17 MiB
NumGC = 2598
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 1.25173295s
Rate: 159778.49 msgs/sec
⏳ Waiting for subscriber to finish or drain...
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 2.967286369s
Rate: 67401.65 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 3.027909743s
End-to-End Rate: 66052.17 msgs/sec
Throughput: 645.04 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 4136 MiB
Sys = 18 MiB
NumGC = 1668
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 20 -workers 4 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 1.054890145s
Rate: 189593.20 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200001/200000 in 1.098481843s
End-to-End Rate: 182070.37 msgs/sec
Throughput: 3.47 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 282 MiB
Sys = 18 MiB
NumGC = 95
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 484.287078ms
Rate: 412978.19 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200019/200000 in 611.335436ms
End-to-End Rate: 327183.72 msgs/sec
Throughput: 6.24 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 1137 MiB
Sys = 21 MiB
NumGC = 588
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 154.866123ms
Rate: 1291438.02 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 264.232584ms
End-to-End Rate: 756908.92 msgs/sec
Throughput: 14.44 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 108 MiB
Sys = 18 MiB
NumGC = 47
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 128 -workers 4 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 660.260654ms
Rate: 302910.67 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 787.888012ms
End-to-End Rate: 253843.18 msgs/sec
Throughput: 30.99 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 353 MiB
Sys = 17 MiB
NumGC = 119
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 623.472669ms
Rate: 320783.91 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200008/200000 in 803.194304ms
End-to-End Rate: 249015.71 msgs/sec
Throughput: 30.40 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 1156 MiB
Sys = 21 MiB
NumGC = 590
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 722.421493ms
Rate: 276846.69 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 849.012064ms
End-to-End Rate: 235567.91 msgs/sec
Throughput: 28.76 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 127 MiB
Sys = 22 MiB
NumGC = 52
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 1024 -workers 4 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 2.224096717s
Rate: 89924.15 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 2.239910276s
End-to-End Rate: 89289.29 msgs/sec
Throughput: 87.20 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 903 MiB
Sys = 18 MiB
NumGC = 320
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 724.298736ms
Rate: 276129.16 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 90879/200000 in 741.488977ms
End-to-End Rate: 122562.85 msgs/sec
Throughput: 119.69 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 940 MiB
Sys = 17 MiB
NumGC = 534
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 807.692765ms
Rate: 247618.91 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 863.860214ms
End-to-End Rate: 231518.94 msgs/sec
Throughput: 226.09 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 300 MiB
Sys = 18 MiB
NumGC = 109
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 10240 -workers 4 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (10240 bytes each) with QoS 0...
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (10240 bytes each) with QoS 0...
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 2.271013162s
Rate: 88066.42 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 2.327890698s
End-to-End Rate: 85914.69 msgs/sec
Throughput: 839.01 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 4136 MiB
Sys = 18 MiB
NumGC = 1796
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 20 -workers 20 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 926.469418ms
Rate: 215873.29 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 968.642627ms
End-to-End Rate: 206474.50 msgs/sec
Throughput: 3.94 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 282 MiB
Sys = 18 MiB
NumGC = 96
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 619.810559ms
Rate: 322679.24 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200013/200000 in 732.503212ms
End-to-End Rate: 273054.09 msgs/sec
Throughput: 5.21 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 1138 MiB
Sys = 21 MiB
NumGC = 627
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 261.225104ms
Rate: 765623.20 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 395.245713ms
End-to-End Rate: 506014.34 msgs/sec
Throughput: 9.65 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 108 MiB
Sys = 23 MiB
NumGC = 49
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 128 -workers 20 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 850.189714ms
Rate: 235241.61 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 900.774324ms
End-to-End Rate: 222031.20 msgs/sec
Throughput: 27.10 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 353 MiB
Sys = 18 MiB
NumGC = 127
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 725.487177ms
Rate: 275676.82 msgs/sec
⏳ Waiting for subscriber to finish or drain...
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 882.502995ms
Rate: 226628.13 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 1.000628346s
End-to-End Rate: 199874.41 msgs/sec
Throughput: 24.40 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 128 MiB
Sys = 23 MiB
NumGC = 60
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 1024 -workers 20 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 1.245432835s
Rate: 160586.74 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 1.245596267s
End-to-End Rate: 160565.67 msgs/sec
Throughput: 156.80 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 903 MiB
Sys = 18 MiB
NumGC = 332
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 723.617221ms
Rate: 276389.22 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 91979/200000 in 2.585928205s
End-to-End Rate: 35569.05 msgs/sec
Throughput: 34.74 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 952 MiB
Sys = 18 MiB
NumGC = 609
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 1.066622185s
Rate: 187507.82 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 1.13008592s
End-to-End Rate: 176977.69 msgs/sec
Throughput: 172.83 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 303 MiB
Sys = 23 MiB
NumGC = 140
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 10240 -workers 20 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 2.932647257s
Rate: 68197.77 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 2.936654827s
End-to-End Rate: 68104.70 msgs/sec
Throughput: 665.08 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 6370 MiB
Sys = 14 MiB
NumGC = 2569
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 1.844376707s
Rate: 108437.72 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 44697/200000 in 1.880134946s
End-to-End Rate: 23773.29 msgs/sec
Throughput: 232.16 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 2682 MiB
Sys = 17 MiB
NumGC = 1685
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 2.952352266s
Rate: 67742.59 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 2.970383853s
End-to-End Rate: 67331.37 msgs/sec
Throughput: 657.53 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 4136 MiB
Sys = 18 MiB
NumGC = 1783
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 20 -workers 50 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 713.353699ms
Rate: 280365.83 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200001/200000 in 755.675361ms
End-to-End Rate: 264665.24 msgs/sec
Throughput: 5.05 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 282 MiB
Sys = 18 MiB
NumGC = 97
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 943.382835ms
Rate: 212003.01 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 1.04412581s
End-to-End Rate: 191547.80 msgs/sec
Throughput: 3.65 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 1137 MiB
Sys = 31 MiB
NumGC = 703
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (20 bytes each) with QoS 0...
📤 Publish done in 318.600369ms
Rate: 627745.66 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 376.811693ms
End-to-End Rate: 530769.09 msgs/sec
Throughput: 10.12 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 109 MiB
Sys = 23 MiB
NumGC = 53
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 128 -workers 50 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 635.423565ms
Rate: 314750.68 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 730.01377ms
End-to-End Rate: 273967.43 msgs/sec
Throughput: 33.44 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 353 MiB
Sys = 13 MiB
NumGC = 120
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 612.963236ms
Rate: 326283.84 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 129576/200000 in 887.813943ms
End-to-End Rate: 145949.50 msgs/sec
Throughput: 17.82 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 789 MiB
Sys = 22 MiB
NumGC = 490
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (128 bytes each) with QoS 0...
📤 Publish done in 795.61215ms
Rate: 251378.77 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 928.382287ms
End-to-End Rate: 215428.50 msgs/sec
Throughput: 26.30 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 128 MiB
Sys = 24 MiB
NumGC = 62
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 1024 -workers 50 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 1.155559617s
Rate: 173076.31 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 1.201835486s
End-to-End Rate: 166412.13 msgs/sec
Throughput: 162.51 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 903 MiB
Sys = 18 MiB
NumGC = 343
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 2.228696015s
Rate: 89738.57 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 109798/200000 in 2.265349615s
End-to-End Rate: 48468.46 msgs/sec
Throughput: 47.33 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 1112 MiB
Sys = 18 MiB
NumGC = 742
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (1024 bytes each) with QoS 0...
📤 Publish done in 954.26892ms
Rate: 209584.53 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 1.019211947s
End-to-End Rate: 196230.04 msgs/sec
Throughput: 191.63 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 303 MiB
Sys = 23 MiB
NumGC = 158
./run_all.sh -server tcp://127.0.0.1:1883 -count 200000 -size 10240 -workers 50 -qos 0
paho_v3
✅ Paho v3 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v3 publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 3.481610571s
Rate: 57444.68 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 3.484617665s
End-to-End Rate: 57395.11 msgs/sec
Throughput: 560.50 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 6370 MiB
Sys = 14 MiB
NumGC = 2763
paho_v5
✅ Paho v5 Subscriber connected. Expecting 200000 messages...
🚀 Starting Paho v5 publish of 200000 messages (10240 bytes each) with QoS 0...
mq
✅ Subscriber connected and ready. Expecting 200000 messages...
🚀 Starting publish of 200000 messages (10240 bytes each) with QoS 0...
📤 Publish done in 3.169492401s
Rate: 63101.59 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 200000/200000 in 3.233616669s
End-to-End Rate: 61850.25 msgs/sec
Throughput: 604.01 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 4136 MiB
Sys = 31 MiB
NumGC = 1927
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 20 -workers 1 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 931.893129ms
Rate: 42923.38 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40020/40000 in 931.945997ms
End-to-End Rate: 42942.40 msgs/sec
Throughput: 0.82 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 84 MiB
Sys = 13 MiB
NumGC = 26
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 1.00076463s
Rate: 39969.44 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.000815504s
End-to-End Rate: 39967.41 msgs/sec
Throughput: 0.76 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 396 MiB
Sys = 17 MiB
NumGC = 240
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 924.763645ms
Rate: 43254.30 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 924.832783ms
End-to-End Rate: 43251.06 msgs/sec
Throughput: 0.82 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 28 MiB
Sys = 13 MiB
NumGC = 8
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 128 -workers 1 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 1.095701996s
Rate: 36506.28 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40025/40000 in 1.09575276s
End-to-End Rate: 36527.40 msgs/sec
Throughput: 4.46 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 98 MiB
Sys = 13 MiB
NumGC = 31
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 1.258922478s
Rate: 31773.20 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.258993799s
End-to-End Rate: 31771.40 msgs/sec
Throughput: 3.88 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 405 MiB
Sys = 17 MiB
NumGC = 250
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 939.712112ms
Rate: 42566.23 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 939.761984ms
End-to-End Rate: 42563.97 msgs/sec
Throughput: 5.20 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 32 MiB
Sys = 13 MiB
NumGC = 10
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 1024 -workers 1 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 1.061517206s
Rate: 37681.91 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.061555717s
End-to-End Rate: 37680.55 msgs/sec
Throughput: 36.80 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 208 MiB
Sys = 17 MiB
NumGC = 66
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 1.439040907s
Rate: 27796.29 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.439116917s
End-to-End Rate: 27794.82 msgs/sec
Throughput: 27.14 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 598 MiB
Sys = 18 MiB
NumGC = 417
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 927.839469ms
Rate: 43110.91 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 927.889852ms
End-to-End Rate: 43108.57 msgs/sec
Throughput: 42.10 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 66 MiB
Sys = 13 MiB
NumGC = 20
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 10240 -workers 1 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 2.133858307s
Rate: 18745.39 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 2.133917265s
End-to-End Rate: 18744.87 msgs/sec
Throughput: 183.06 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 1303 MiB
Sys = 13 MiB
NumGC = 445
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 2.880368544s
Rate: 13887.11 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 2.880479118s
End-to-End Rate: 13886.58 msgs/sec
Throughput: 135.61 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 2903 MiB
Sys = 18 MiB
NumGC = 2394
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.869915938s
Rate: 21391.34 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.869981699s
End-to-End Rate: 21390.58 msgs/sec
Throughput: 208.89 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 838 MiB
Sys = 13 MiB
NumGC = 278
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 20 -workers 4 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 483.01934ms
Rate: 82812.42 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 483.08996ms
End-to-End Rate: 82800.31 msgs/sec
Throughput: 1.58 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 84 MiB
Sys = 17 MiB
NumGC = 29
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 621.780684ms
Rate: 64331.36 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 621.866502ms
End-to-End Rate: 64322.49 msgs/sec
Throughput: 1.23 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 396 MiB
Sys = 18 MiB
NumGC = 273
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 338.76012ms
Rate: 118077.65 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 338.835259ms
End-to-End Rate: 118051.47 msgs/sec
Throughput: 2.25 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 28 MiB
Sys = 13 MiB
NumGC = 9
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 128 -workers 4 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 454.954036ms
Rate: 87920.97 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 455.031099ms
End-to-End Rate: 87906.08 msgs/sec
Throughput: 10.73 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 98 MiB
Sys = 18 MiB
NumGC = 35
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 699.914523ms
Rate: 57149.84 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 700.015029ms
End-to-End Rate: 57141.63 msgs/sec
Throughput: 6.98 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 406 MiB
Sys = 18 MiB
NumGC = 290
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 366.233841ms
Rate: 109219.84 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 366.464737ms
End-to-End Rate: 109151.02 msgs/sec
Throughput: 13.32 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 32 MiB
Sys = 17 MiB
NumGC = 10
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 1024 -workers 4 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 537.416252ms
Rate: 74430.20 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 537.49619ms
End-to-End Rate: 74419.13 msgs/sec
Throughput: 72.67 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 208 MiB
Sys = 17 MiB
NumGC = 75
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 788.413036ms
Rate: 50734.83 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 788.629065ms
End-to-End Rate: 50720.93 msgs/sec
Throughput: 49.53 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 599 MiB
Sys = 18 MiB
NumGC = 431
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 510.693374ms
Rate: 78324.89 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 510.808687ms
End-to-End Rate: 78307.20 msgs/sec
Throughput: 76.47 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 67 MiB
Sys = 18 MiB
NumGC = 22
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 10240 -workers 4 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.248621854s
Rate: 32035.32 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.24874409s
End-to-End Rate: 32032.18 msgs/sec
Throughput: 312.81 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 1304 MiB
Sys = 13 MiB
NumGC = 511
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.472886672s
Rate: 27157.55 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 34429/40000 in 1.514670032s
End-to-End Rate: 22730.36 msgs/sec
Throughput: 221.98 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 2581 MiB
Sys = 19 MiB
NumGC = 1770
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.136389334s
Rate: 35199.20 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.136517941s
End-to-End Rate: 35195.22 msgs/sec
Throughput: 343.70 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 842 MiB
Sys = 14 MiB
NumGC = 331
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 20 -workers 20 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 481.301442ms
Rate: 83108.00 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 481.491673ms
End-to-End Rate: 83075.16 msgs/sec
Throughput: 1.58 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 84 MiB
Sys = 18 MiB
NumGC = 29
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 592.613204ms
Rate: 67497.65 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 592.798166ms
End-to-End Rate: 67476.59 msgs/sec
Throughput: 1.29 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 397 MiB
Sys = 19 MiB
NumGC = 315
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 350.661161ms
Rate: 114070.23 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 350.853496ms
End-to-End Rate: 114007.70 msgs/sec
Throughput: 2.17 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 28 MiB
Sys = 13 MiB
NumGC = 9
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 128 -workers 20 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 481.225188ms
Rate: 83121.17 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 481.378401ms
End-to-End Rate: 83094.71 msgs/sec
Throughput: 10.14 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 98 MiB
Sys = 18 MiB
NumGC = 35
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 548.530209ms
Rate: 72922.15 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 548.655851ms
End-to-End Rate: 72905.45 msgs/sec
Throughput: 8.90 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 406 MiB
Sys = 18 MiB
NumGC = 309
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 262.132374ms
Rate: 152594.66 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 262.274757ms
End-to-End Rate: 152511.82 msgs/sec
Throughput: 18.62 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 32 MiB
Sys = 18 MiB
NumGC = 11
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 1024 -workers 20 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 509.461046ms
Rate: 78514.34 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 509.622594ms
End-to-End Rate: 78489.46 msgs/sec
Throughput: 76.65 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 208 MiB
Sys = 18 MiB
NumGC = 78
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 734.798814ms
Rate: 54436.67 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 734.93176ms
End-to-End Rate: 54426.82 msgs/sec
Throughput: 53.15 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 600 MiB
Sys = 19 MiB
NumGC = 466
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 370.240759ms
Rate: 108037.81 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 370.390656ms
End-to-End Rate: 107994.09 msgs/sec
Throughput: 105.46 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 67 MiB
Sys = 18 MiB
NumGC = 23
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 10240 -workers 20 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 885.015128ms
Rate: 45196.97 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 885.159484ms
End-to-End Rate: 45189.60 msgs/sec
Throughput: 441.30 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 1304 MiB
Sys = 18 MiB
NumGC = 574
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.198728515s
Rate: 33368.69 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 23361/40000 in 1.238494423s
End-to-End Rate: 18862.42 msgs/sec
Throughput: 184.20 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 1939 MiB
Sys = 19 MiB
NumGC = 1332
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.17536027s
Rate: 34032.12 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.176062618s
End-to-End Rate: 34011.79 msgs/sec
Throughput: 332.15 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 842 MiB
Sys = 18 MiB
NumGC = 358
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 20 -workers 50 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 475.508356ms
Rate: 84120.50 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 475.635921ms
End-to-End Rate: 84097.94 msgs/sec
Throughput: 1.60 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 84 MiB
Sys = 18 MiB
NumGC = 31
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 706.382842ms
Rate: 56626.52 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 706.593732ms
End-to-End Rate: 56609.62 msgs/sec
Throughput: 1.08 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 397 MiB
Sys = 23 MiB
NumGC = 330
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (20 bytes each) with QoS 1...
📤 Publish done in 308.127567ms
Rate: 129816.36 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 308.255133ms
End-to-End Rate: 129762.64 msgs/sec
Throughput: 2.48 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 28 MiB
Sys = 18 MiB
NumGC = 10
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 128 -workers 50 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 487.463975ms
Rate: 82057.35 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 487.633578ms
End-to-End Rate: 82028.81 msgs/sec
Throughput: 10.01 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 98 MiB
Sys = 18 MiB
NumGC = 37
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 648.269499ms
Rate: 61702.73 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 648.40516ms
End-to-End Rate: 61689.82 msgs/sec
Throughput: 7.53 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 407 MiB
Sys = 18 MiB
NumGC = 341
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (128 bytes each) with QoS 1...
📤 Publish done in 210.643152ms
Rate: 189894.61 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 210.775297ms
End-to-End Rate: 189775.56 msgs/sec
Throughput: 23.17 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 32 MiB
Sys = 18 MiB
NumGC = 12
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 1024 -workers 50 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 517.828846ms
Rate: 77245.60 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 518.002427ms
End-to-End Rate: 77219.72 msgs/sec
Throughput: 75.41 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 208 MiB
Sys = 18 MiB
NumGC = 81
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 665.628757ms
Rate: 60093.56 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 665.829077ms
End-to-End Rate: 60075.48 msgs/sec
Throughput: 58.67 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 600 MiB
Sys = 23 MiB
NumGC = 462
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (1024 bytes each) with QoS 1...
📤 Publish done in 284.186914ms
Rate: 140752.43 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 284.321423ms
End-to-End Rate: 140685.85 msgs/sec
Throughput: 137.39 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 67 MiB
Sys = 18 MiB
NumGC = 23
./run_all.sh -server tcp://127.0.0.1:1883 -count 40000 -size 10240 -workers 50 -qos 1
paho_v3
✅ Paho v3 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v3 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 759.956798ms
Rate: 52634.57 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 36260/40000 in 715.24659ms
End-to-End Rate: 50695.80 msgs/sec
Throughput: 495.08 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 1226 MiB
Sys = 19 MiB
NumGC = 576
paho_v5
✅ Paho v5 Subscriber connected. Expecting 40000 messages...
🚀 Starting Paho v5 publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.198943685s
Rate: 33362.70 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 24101/40000 in 1.221990167s
End-to-End Rate: 19722.74 msgs/sec
Throughput: 192.60 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 1982 MiB
Sys = 23 MiB
NumGC = 1075
mq
✅ Subscriber connected and ready. Expecting 40000 messages...
🚀 Starting publish of 40000 messages (10240 bytes each) with QoS 1...
📤 Publish done in 1.103153028s
Rate: 36259.70 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 40000/40000 in 1.103382001s
End-to-End Rate: 36252.18 msgs/sec
Throughput: 354.03 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 842 MiB
Sys = 18 MiB
NumGC = 389
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 20 -workers 1 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 645.400411ms
Rate: 23241.39 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 645.459109ms
End-to-End Rate: 23239.27 msgs/sec
Throughput: 0.44 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 46 MiB
Sys = 13 MiB
NumGC = 14
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 861.07354ms
Rate: 17420.11 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 861.152365ms
End-to-End Rate: 17418.52 msgs/sec
Throughput: 0.33 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 233 MiB
Sys = 18 MiB
NumGC = 135
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 544.838501ms
Rate: 27531.09 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 544.894053ms
End-to-End Rate: 27528.29 msgs/sec
Throughput: 0.53 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 13 MiB
Sys = 13 MiB
NumGC = 4
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 128 -workers 1 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 706.577869ms
Rate: 21229.08 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 706.626879ms
End-to-End Rate: 21227.61 msgs/sec
Throughput: 2.59 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 51 MiB
Sys = 13 MiB
NumGC = 16
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 796.401168ms
Rate: 18834.73 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 796.471728ms
End-to-End Rate: 18833.06 msgs/sec
Throughput: 2.30 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 237 MiB
Sys = 14 MiB
NumGC = 139
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 631.713683ms
Rate: 23744.93 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 631.78269ms
End-to-End Rate: 23742.34 msgs/sec
Throughput: 2.90 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 15 MiB
Sys = 13 MiB
NumGC = 4
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 1024 -workers 1 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 739.829383ms
Rate: 20274.94 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 739.889403ms
End-to-End Rate: 20273.30 msgs/sec
Throughput: 19.80 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 93 MiB
Sys = 13 MiB
NumGC = 29
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 1.03858317s
Rate: 14442.75 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 1.038655954s
End-to-End Rate: 14441.74 msgs/sec
Throughput: 14.10 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 309 MiB
Sys = 14 MiB
NumGC = 208
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 596.12393ms
Rate: 25162.55 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 596.177038ms
End-to-End Rate: 25160.31 msgs/sec
Throughput: 24.57 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 28 MiB
Sys = 13 MiB
NumGC = 8
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 10240 -workers 1 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 928.765753ms
Rate: 16150.47 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 928.824672ms
End-to-End Rate: 16149.44 msgs/sec
Throughput: 157.71 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 503 MiB
Sys = 13 MiB
NumGC = 167
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 1.304746658s
Rate: 11496.48 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 1.304814102s
End-to-End Rate: 11495.89 msgs/sec
Throughput: 112.26 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 1174 MiB
Sys = 18 MiB
NumGC = 1043
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 681.304253ms
Rate: 22016.60 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 681.372198ms
End-to-End Rate: 22014.40 msgs/sec
Throughput: 214.98 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 317 MiB
Sys = 13 MiB
NumGC = 105
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 20 -workers 4 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 363.947183ms
Rate: 41214.77 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 364.060272ms
End-to-End Rate: 41201.97 msgs/sec
Throughput: 0.79 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 46 MiB
Sys = 18 MiB
NumGC = 15
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 428.773144ms
Rate: 34983.53 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 428.868571ms
End-to-End Rate: 34975.75 msgs/sec
Throughput: 0.67 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 233 MiB
Sys = 17 MiB
NumGC = 159
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 247.598884ms
Rate: 60581.86 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 247.7483ms
End-to-End Rate: 60545.32 msgs/sec
Throughput: 1.15 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 13 MiB
Sys = 17 MiB
NumGC = 4
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 128 -workers 4 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 398.775539ms
Rate: 37615.15 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 398.90067ms
End-to-End Rate: 37603.35 msgs/sec
Throughput: 4.59 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 51 MiB
Sys = 17 MiB
NumGC = 17
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 421.340145ms
Rate: 35600.69 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 421.492216ms
End-to-End Rate: 35587.85 msgs/sec
Throughput: 4.34 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 237 MiB
Sys = 17 MiB
NumGC = 164
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 257.605941ms
Rate: 58228.47 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 257.681661ms
End-to-End Rate: 58211.36 msgs/sec
Throughput: 7.11 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 15 MiB
Sys = 13 MiB
NumGC = 4
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 1024 -workers 4 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 325.816214ms
Rate: 46038.22 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 325.883558ms
End-to-End Rate: 46028.71 msgs/sec
Throughput: 44.95 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 93 MiB
Sys = 17 MiB
NumGC = 32
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 465.454272ms
Rate: 32226.58 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 465.542144ms
End-to-End Rate: 32220.50 msgs/sec
Throughput: 31.47 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 309 MiB
Sys = 18 MiB
NumGC = 227
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 281.195043ms
Rate: 53343.76 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 281.287404ms
End-to-End Rate: 53326.24 msgs/sec
Throughput: 52.08 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 28 MiB
Sys = 17 MiB
NumGC = 9
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 10240 -workers 4 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 478.939497ms
Rate: 31319.20 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 479.076741ms
End-to-End Rate: 31310.22 msgs/sec
Throughput: 305.76 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 503 MiB
Sys = 14 MiB
NumGC = 199
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 877.096281ms
Rate: 17101.89 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 880.304059ms
End-to-End Rate: 17039.57 msgs/sec
Throughput: 166.40 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 1174 MiB
Sys = 18 MiB
NumGC = 830
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 389.949087ms
Rate: 38466.56 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 390.059361ms
End-to-End Rate: 38455.69 msgs/sec
Throughput: 375.54 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 318 MiB
Sys = 13 MiB
NumGC = 114
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 20 -workers 20 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 353.347165ms
Rate: 42451.17 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 353.470984ms
End-to-End Rate: 42436.30 msgs/sec
Throughput: 0.81 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 46 MiB
Sys = 17 MiB
NumGC = 16
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 445.533527ms
Rate: 33667.50 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 445.694004ms
End-to-End Rate: 33655.38 msgs/sec
Throughput: 0.64 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 234 MiB
Sys = 18 MiB
NumGC = 182
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 156.446651ms
Rate: 95879.33 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 156.658162ms
End-to-End Rate: 95749.88 msgs/sec
Throughput: 1.83 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 13 MiB
Sys = 18 MiB
NumGC = 4
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 128 -workers 20 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 354.786959ms
Rate: 42278.89 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 354.945923ms
End-to-End Rate: 42259.96 msgs/sec
Throughput: 5.16 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 51 MiB
Sys = 18 MiB
NumGC = 18
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 471.259726ms
Rate: 31829.58 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 471.369298ms
End-to-End Rate: 31822.18 msgs/sec
Throughput: 3.88 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 237 MiB
Sys = 19 MiB
NumGC = 196
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 166.906292ms
Rate: 89870.79 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 167.031393ms
End-to-End Rate: 89803.48 msgs/sec
Throughput: 10.96 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 15 MiB
Sys = 18 MiB
NumGC = 5
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 1024 -workers 20 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 375.189457ms
Rate: 39979.80 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 375.378356ms
End-to-End Rate: 39959.68 msgs/sec
Throughput: 39.02 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 93 MiB
Sys = 18 MiB
NumGC = 33
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 459.75379ms
Rate: 32626.16 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 459.948229ms
End-to-End Rate: 32612.37 msgs/sec
Throughput: 31.85 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 310 MiB
Sys = 18 MiB
NumGC = 257
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 181.027919ms
Rate: 82860.15 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 181.15844ms
End-to-End Rate: 82800.45 msgs/sec
Throughput: 80.86 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 28 MiB
Sys = 18 MiB
NumGC = 9
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 10240 -workers 20 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 470.398846ms
Rate: 31887.83 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 470.52508ms
End-to-End Rate: 31879.28 msgs/sec
Throughput: 311.32 MB/sec
💾 Memory Usage:
Alloc = 3 MiB
TotalAlloc = 504 MiB
Sys = 18 MiB
NumGC = 252
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 638.721634ms
Rate: 23484.41 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 11627/15000 in 688.350857ms
End-to-End Rate: 16891.10 msgs/sec
Throughput: 164.95 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 969 MiB
Sys = 18 MiB
NumGC = 653
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 521.542485ms
Rate: 28760.84 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 521.691821ms
End-to-End Rate: 28752.61 msgs/sec
Throughput: 280.79 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 319 MiB
Sys = 13 MiB
NumGC = 127
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 20 -workers 50 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 352.058155ms
Rate: 42606.60 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 352.215465ms
End-to-End Rate: 42587.57 msgs/sec
Throughput: 0.81 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 46 MiB
Sys = 18 MiB
NumGC = 16
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 510.151034ms
Rate: 29403.06 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 510.357395ms
End-to-End Rate: 29391.17 msgs/sec
Throughput: 0.56 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 234 MiB
Sys = 18 MiB
NumGC = 180
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (20 bytes each) with QoS 2...
📤 Publish done in 245.457667ms
Rate: 61110.33 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 245.642618ms
End-to-End Rate: 61064.32 msgs/sec
Throughput: 1.16 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 13 MiB
Sys = 18 MiB
NumGC = 5
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 128 -workers 50 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 354.499491ms
Rate: 42313.18 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 354.647896ms
End-to-End Rate: 42295.47 msgs/sec
Throughput: 5.16 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 51 MiB
Sys = 18 MiB
NumGC = 18
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 426.705824ms
Rate: 35153.02 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 426.901856ms
End-to-End Rate: 35136.88 msgs/sec
Throughput: 4.29 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 237 MiB
Sys = 19 MiB
NumGC = 191
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (128 bytes each) with QoS 2...
📤 Publish done in 192.93987ms
Rate: 77744.43 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 193.119943ms
End-to-End Rate: 77671.94 msgs/sec
Throughput: 9.48 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 15 MiB
Sys = 18 MiB
NumGC = 5
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 1024 -workers 50 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 366.793076ms
Rate: 40894.99 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 366.9466ms
End-to-End Rate: 40877.88 msgs/sec
Throughput: 39.92 MB/sec
💾 Memory Usage:
Alloc = 0 MiB
TotalAlloc = 93 MiB
Sys = 17 MiB
NumGC = 35
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 456.958396ms
Rate: 32825.75 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 457.072196ms
End-to-End Rate: 32817.57 msgs/sec
Throughput: 32.05 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 310 MiB
Sys = 19 MiB
NumGC = 243
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (1024 bytes each) with QoS 2...
📤 Publish done in 257.457993ms
Rate: 58261.93 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 257.616997ms
End-to-End Rate: 58225.97 msgs/sec
Throughput: 56.86 MB/sec
💾 Memory Usage:
Alloc = 1 MiB
TotalAlloc = 28 MiB
Sys = 18 MiB
NumGC = 10
./run_all.sh -server tcp://127.0.0.1:1883 -count 15000 -size 10240 -workers 50 -qos 2
paho_v3
✅ Paho v3 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v3 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 486.138138ms
Rate: 30855.43 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 486.300108ms
End-to-End Rate: 30845.15 msgs/sec
Throughput: 301.22 MB/sec
💾 Memory Usage:
Alloc = 4 MiB
TotalAlloc = 504 MiB
Sys = 19 MiB
NumGC = 200
paho_v5
✅ Paho v5 Subscriber connected. Expecting 15000 messages...
🚀 Starting Paho v5 publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 891.548835ms
Rate: 16824.65 msgs/sec
⏳ Waiting for subscriber to finish or drain...
⚠️ Subscriber idle for 2s (likely dropped messages), stopping.
✅ Messages received: 12153/15000 in 891.465161ms
End-to-End Rate: 13632.61 msgs/sec
Throughput: 133.13 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 1001 MiB
Sys = 19 MiB
NumGC = 581
mq
✅ Subscriber connected and ready. Expecting 15000 messages...
🚀 Starting publish of 15000 messages (10240 bytes each) with QoS 2...
📤 Publish done in 442.861466ms
Rate: 33870.64 msgs/sec
⏳ Waiting for subscriber to finish or drain...
✅ Messages received: 15000/15000 in 443.055234ms
End-to-End Rate: 33855.82 msgs/sec
Throughput: 330.62 MB/sec
💾 Memory Usage:
Alloc = 2 MiB
TotalAlloc = 319 MiB
Sys = 18 MiB
NumGC = 138
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment