Trend: JetStream - Recent commits to 'main' branch

Show jobs details
Job Source Filter Repetitions Go Worker Job Info
7a548ed0-d94f-47e4-b23c-fb8562fabc16 main
https://github.com/nats-io/nats-server.git
(48a757ba3fcb29b31b826821f804e6ebc81ffd2c)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-08 00:00:20 +0000 UTC
1a9f0900-4a21-494b-b8c0-6ed239128bd7 main
https://github.com/nats-io/nats-server.git
(425cf16ebbc89b64079ba56faf54d812a4d59d93)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-09 00:00:14 +0000 UTC
36519ff8-21e8-42ba-818f-535287807819 main
https://github.com/nats-io/nats-server.git
(12bc38e37154333ff6c69d34000e02f3492504bf)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-10 00:00:25 +0000 UTC
21c9bb25-bf58-46fd-adf1-184886ab3efa main
https://github.com/nats-io/nats-server.git
(d1bf5a76f4f0e321eaaa30f9c54b3e3f3deccc77)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-13 00:00:12 +0000 UTC
03401b01-26ef-4e84-95d1-a71bbda885a7 main
https://github.com/nats-io/nats-server.git
(91602f9c88fed760281c14758cd7779bb4d3a0d2)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-14 00:00:13 +0000 UTC
41b06380-aad7-4470-a602-0f40ec419201 main
https://github.com/nats-io/nats-server.git
(c739352690e08eec8bbd0c0655fb27e96bbf4025)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-15 00:00:13 +0000 UTC
55619889-b76b-407c-b74a-35030f17eb06 main
https://github.com/nats-io/nats-server.git
(d897a1aedabf53423a5b7d54b5f1e7eed7de71ea)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-19 00:00:22 +0000 UTC
f8282b59-6db2-4274-a439-ef7d120a96f8 main
https://github.com/nats-io/nats-server.git
(7885ebd0687ed7c31e441e2c752397261e45ca09)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-21 00:00:23 +0000 UTC
bafa8372-2020-4620-8660-6bae41a86db6 main
https://github.com/nats-io/nats-server.git
(192d2bfa6e20e3879758b765e14a0a772c0a0f2f)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-24 00:00:18 +0000 UTC
a6430a6f-c254-4082-91df-fbf5f0cbfbad main
https://github.com/nats-io/nats-server.git
(85594c8ce6b253d8552efc602360929fc22fd583)		 BenchmarkJetStream(Publish|Consume).*/.*R=3.* 5 x 3s go version go1.25.1 linux/amd64
(/usr/local/go1.25.1/bin/go)		 dev (?)
eu-amsterdam1.nats-demo.equinix.synadia.net
Linux_5.15.0-156-generic-x86_64		 Submitted by at 2025-10-25 00:00:19 +0000 UTC

Push Consumer throughput (msg/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsume/.*/PUSH.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 496k ± 9k 538k ± 40k 517k ± 62k 537k ± 47k 537k ± 42k 548k ± 31k 536k ± 42k 534k ± 48k 506k ± 9k 541k ± 53k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 538k ± 8k 571k ± 97k 568k ± 100k 616k ± 56k 544k ± 2k 573k ± 97k 545k ± 6k 585k ± 73k 540k ± 5k 549k ± 5k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 1.04M ± 0.09M 1.08M ± 0.05M 1.04M ± 0.00M 1.08M ± 0.05M 1.08M ± 0.06M 1.08M ± 0.05M 1.07M ± 0.05M 1.05M ± 0.02M 1.06M ± 0.08M 1.06M ± 0.09M
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 358k ± 51k 407k ± 40k 383k ± 60k 374k ± 67k 384k ± 2k 373k ± 74k 400k ± 45k 401k ± 35k 371k ± 40k 358k ± 58k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 427k ± 26k 415k ± 36k 436k ± 14k 386k ± 69k 402k ± 0k 404k ± 2k 411k ± 41k 403k ± 3k 422k ± 30k 426k ± 29k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 478k ± 51k 480k ± 55k 499k ± 37k 479k ± 55k 495k ± 43k 509k ± 35k 490k ± 47k 473k ± 59k 483k ± 46k 467k ± 1k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 330k ± 48k 327k ± 26k 306k ± 35k 355k ± 7k 323k ± 29k 286k ± 54k 305k ± 38k 303k ± 51k 312k ± 69k 331k ± 54k

Push Consumer throughput (byte/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsume/.*/PUSH.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 4.96MB/s ± 0.09MB/s 5.38MB/s ± 0.40MB/s 5.17MB/s ± 0.62MB/s 5.37MB/s ± 0.47MB/s 5.37MB/s ± 0.42MB/s 5.48MB/s ± 0.31MB/s 5.36MB/s ± 0.42MB/s 5.34MB/s ± 0.48MB/s 5.06MB/s ± 0.09MB/s 5.41MB/s ± 0.53MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 5.38MB/s ± 0.08MB/s 5.46MB/s ± 0.08MB/s 5.44MB/s ± 0.08MB/s 6.16MB/s ± 0.56MB/s 5.44MB/s ± 0.02MB/s 5.73MB/s ± 0.97MB/s 5.45MB/s ± 0.06MB/s 5.85MB/s ± 0.73MB/s 5.40MB/s ± 0.05MB/s 5.49MB/s ± 0.05MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 10.4MB/s ± 1.0MB/s 10.8MB/s ± 0.5MB/s 10.4MB/s ± 0.0MB/s 10.8MB/s ± 0.5MB/s 10.8MB/s ± 0.6MB/s 10.8MB/s ± 0.5MB/s 10.7MB/s ± 0.5MB/s 10.5MB/s ± 0.2MB/s 10.6MB/s ± 0.8MB/s 10.6MB/s ± 0.9MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 3.58MB/s ± 0.51MB/s 4.07MB/s ± 0.39MB/s 3.83MB/s ± 0.60MB/s 3.74MB/s ± 0.67MB/s 3.84MB/s ± 0.02MB/s 3.73MB/s ± 0.74MB/s 4.00MB/s ± 0.45MB/s 4.00MB/s ± 0.35MB/s 3.71MB/s ± 0.40MB/s 3.58MB/s ± 0.58MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 438MB/s ± 27MB/s 425MB/s ± 37MB/s 446MB/s ± 15MB/s 395MB/s ± 70MB/s 412MB/s ± 0MB/s 414MB/s ± 2MB/s 421MB/s ± 42MB/s 413MB/s ± 3MB/s 432MB/s ± 30MB/s 437MB/s ± 30MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 489MB/s ± 52MB/s 491MB/s ± 57MB/s 511MB/s ± 38MB/s 491MB/s ± 57MB/s 507MB/s ± 44MB/s 522MB/s ± 36MB/s 502MB/s ± 48MB/s 484MB/s ± 60MB/s 494MB/s ± 47MB/s 478MB/s ± 1MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 338MB/s ± 50MB/s 335MB/s ± 27MB/s 313MB/s ± 36MB/s 364MB/s ± 7MB/s 330MB/s ± 29MB/s 293MB/s ± 55MB/s 312MB/s ± 39MB/s 310MB/s ± 52MB/s 319MB/s ± 70MB/s 339MB/s ± 55MB/s

Pull Consumer throughput (msg/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsume/.*/PULL.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 239k ± 40k 240k ± 42k 258k ± 24k 240k ± 40k 219k ± 25k 236k ± 47k 246k ± 30k 215k ± 4k 235k ± 36k 216k ± 58k
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 323k ± 64k 315k ± 5k 345k ± 48k 309k ± 1k 311k ± 1k 313k ± 4k 314k ± 3k 341k ± 45k 311k ± 1k 316k ± 3k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 191k ± 3k 193k ± 2k 193k ± 2k 200k ± 19k 213k ± 29k 190k ± 4k 202k ± 38k 192k ± 3k 192k ± 2k 195k ± 2k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 270k ± 4k 273k ± 1k 273k ± 2k 279k ± 50k 271k ± 1k 274k ± 2k 298k ± 40k 271k ± 2k 269k ± 3k 275k ± 2k

Pull Consumer throughput (byte/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsume/.*/PULL.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 2.39MB/s ± 0.40MB/s 2.40MB/s ± 0.42MB/s 2.58MB/s ± 0.24MB/s 2.40MB/s ± 0.40MB/s 2.19MB/s ± 0.25MB/s 2.36MB/s ± 0.48MB/s 2.46MB/s ± 0.30MB/s 2.15MB/s ± 0.04MB/s 2.35MB/s ± 0.36MB/s 2.16MB/s ± 0.58MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 3.07MB/s ± 0.05MB/s 3.15MB/s ± 0.06MB/s 3.45MB/s ± 0.48MB/s 3.09MB/s ± 0.01MB/s 3.11MB/s ± 0.01MB/s 3.12MB/s ± 0.04MB/s 3.14MB/s ± 0.03MB/s 3.41MB/s ± 0.45MB/s 3.11MB/s ± 0.02MB/s 3.16MB/s ± 0.03MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 195MB/s ± 3MB/s 198MB/s ± 2MB/s 198MB/s ± 2MB/s 205MB/s ± 19MB/s 218MB/s ± 30MB/s 195MB/s ± 4MB/s 197MB/s ± 3MB/s 196MB/s ± 3MB/s 197MB/s ± 2MB/s 199MB/s ± 2MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 276MB/s ± 4MB/s 279MB/s ± 1MB/s 279MB/s ± 2MB/s 286MB/s ± 51MB/s 277MB/s ± 1MB/s 280MB/s ± 2MB/s 305MB/s ± 41MB/s 278MB/s ± 2MB/s 275MB/s ± 3MB/s 282MB/s ± 2MB/s

Consume throughput (msg/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsume/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 496k ± 9k 538k ± 40k 517k ± 62k 537k ± 47k 537k ± 42k 548k ± 31k 536k ± 42k 534k ± 48k 506k ± 9k 541k ± 53k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 538k ± 8k 571k ± 97k 568k ± 100k 616k ± 56k 544k ± 2k 573k ± 97k 545k ± 6k 585k ± 73k 540k ± 5k 549k ± 5k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 1.04M ± 0.09M 1.08M ± 0.05M 1.04M ± 0.00M 1.08M ± 0.05M 1.08M ± 0.06M 1.08M ± 0.05M 1.07M ± 0.05M 1.05M ± 0.02M 1.06M ± 0.08M 1.06M ± 0.09M
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 358k ± 51k 407k ± 40k 383k ± 60k 374k ± 67k 384k ± 2k 373k ± 74k 400k ± 45k 401k ± 35k 371k ± 40k 358k ± 58k
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 239k ± 40k 240k ± 42k 258k ± 24k 240k ± 40k 219k ± 25k 236k ± 47k 246k ± 30k 215k ± 4k 235k ± 36k 216k ± 58k
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 323k ± 64k 315k ± 5k 345k ± 48k 309k ± 1k 311k ± 1k 313k ± 4k 314k ± 3k 341k ± 45k 311k ± 1k 316k ± 3k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 427k ± 26k 415k ± 36k 436k ± 14k 386k ± 69k 402k ± 0k 404k ± 2k 411k ± 41k 403k ± 3k 422k ± 30k 426k ± 29k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 478k ± 51k 480k ± 55k 499k ± 37k 479k ± 55k 495k ± 43k 509k ± 35k 490k ± 47k 473k ± 59k 483k ± 46k 467k ± 1k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 330k ± 48k 327k ± 26k 306k ± 35k 355k ± 7k 323k ± 29k 286k ± 54k 305k ± 38k 303k ± 51k 312k ± 69k 331k ± 54k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 191k ± 3k 193k ± 2k 193k ± 2k 200k ± 19k 213k ± 29k 190k ± 4k 202k ± 38k 192k ± 3k 192k ± 2k 195k ± 2k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 270k ± 4k 273k ± 1k 273k ± 2k 279k ± 50k 271k ± 1k 274k ± 2k 298k ± 40k 271k ± 2k 269k ± 3k 275k ± 2k

Consume throughput (byte/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsume/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 4.96MB/s ± 0.09MB/s 5.38MB/s ± 0.40MB/s 5.17MB/s ± 0.62MB/s 5.37MB/s ± 0.47MB/s 5.37MB/s ± 0.42MB/s 5.48MB/s ± 0.31MB/s 5.36MB/s ± 0.42MB/s 5.34MB/s ± 0.48MB/s 5.06MB/s ± 0.09MB/s 5.41MB/s ± 0.53MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 5.38MB/s ± 0.08MB/s 5.46MB/s ± 0.08MB/s 5.44MB/s ± 0.08MB/s 6.16MB/s ± 0.56MB/s 5.44MB/s ± 0.02MB/s 5.73MB/s ± 0.97MB/s 5.45MB/s ± 0.06MB/s 5.85MB/s ± 0.73MB/s 5.40MB/s ± 0.05MB/s 5.49MB/s ± 0.05MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 10.4MB/s ± 1.0MB/s 10.8MB/s ± 0.5MB/s 10.4MB/s ± 0.0MB/s 10.8MB/s ± 0.5MB/s 10.8MB/s ± 0.6MB/s 10.8MB/s ± 0.5MB/s 10.7MB/s ± 0.5MB/s 10.5MB/s ± 0.2MB/s 10.6MB/s ± 0.8MB/s 10.6MB/s ± 0.9MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 3.58MB/s ± 0.51MB/s 4.07MB/s ± 0.39MB/s 3.83MB/s ± 0.60MB/s 3.74MB/s ± 0.67MB/s 3.84MB/s ± 0.02MB/s 3.73MB/s ± 0.74MB/s 4.00MB/s ± 0.45MB/s 4.00MB/s ± 0.35MB/s 3.71MB/s ± 0.40MB/s 3.58MB/s ± 0.58MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 2.39MB/s ± 0.40MB/s 2.40MB/s ± 0.42MB/s 2.58MB/s ± 0.24MB/s 2.40MB/s ± 0.40MB/s 2.19MB/s ± 0.25MB/s 2.36MB/s ± 0.48MB/s 2.46MB/s ± 0.30MB/s 2.15MB/s ± 0.04MB/s 2.35MB/s ± 0.36MB/s 2.16MB/s ± 0.58MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 3.07MB/s ± 0.05MB/s 3.15MB/s ± 0.06MB/s 3.45MB/s ± 0.48MB/s 3.09MB/s ± 0.01MB/s 3.11MB/s ± 0.01MB/s 3.12MB/s ± 0.04MB/s 3.14MB/s ± 0.03MB/s 3.41MB/s ± 0.45MB/s 3.11MB/s ± 0.02MB/s 3.16MB/s ± 0.03MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 438MB/s ± 27MB/s 425MB/s ± 37MB/s 446MB/s ± 15MB/s 395MB/s ± 70MB/s 412MB/s ± 0MB/s 414MB/s ± 2MB/s 421MB/s ± 42MB/s 413MB/s ± 3MB/s 432MB/s ± 30MB/s 437MB/s ± 30MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 489MB/s ± 52MB/s 491MB/s ± 57MB/s 511MB/s ± 38MB/s 491MB/s ± 57MB/s 507MB/s ± 44MB/s 522MB/s ± 36MB/s 502MB/s ± 48MB/s 484MB/s ± 60MB/s 494MB/s ± 47MB/s 478MB/s ± 1MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 338MB/s ± 50MB/s 335MB/s ± 27MB/s 313MB/s ± 36MB/s 364MB/s ± 7MB/s 330MB/s ± 29MB/s 293MB/s ± 55MB/s 312MB/s ± 39MB/s 310MB/s ± 52MB/s 319MB/s ± 70MB/s 339MB/s ± 55MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 195MB/s ± 3MB/s 198MB/s ± 2MB/s 198MB/s ± 2MB/s 205MB/s ± 19MB/s 218MB/s ± 30MB/s 195MB/s ± 4MB/s 197MB/s ± 3MB/s 196MB/s ± 3MB/s 197MB/s ± 2MB/s 199MB/s ± 2MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 276MB/s ± 4MB/s 279MB/s ± 1MB/s 279MB/s ± 2MB/s 286MB/s ± 51MB/s 277MB/s ± 1MB/s 280MB/s ± 2MB/s 305MB/s ± 41MB/s 278MB/s ± 2MB/s 275MB/s ± 3MB/s 282MB/s ± 2MB/s

Filtered Consumer throughput (op/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsumeWithFilters/.*D=10000.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsumeWithFilters/N=3,R=3,storage=Memory/D=10000,DS=10,F=50,C=12-16 289 ± 2 288 ± 2 290 ± 1 288 ± 2 290 ± 0 290 ± 2 289 ± 2 288 ± 2 289 ± 2 288 ± 1
JetStreamConsumeWithFilters/N=3,R=3,storage=File/D=10000,DS=10,F=50,C=12-16 136 ± 2 136 ± 3 136 ± 2 136 ± 2 138 ± 2 135 ± 1 135 ± 2 136 ± 5 137 ± 1 135 ± 2

Filtered Consumer throughput (op/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsumeWithFilters/.*D=10000.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsumeWithFilters/N=3,R=3,storage=Memory/D=10000,DS=10,F=50,C=12-16 289 ± 2 288 ± 2 290 ± 1 288 ± 2 290 ± 0 290 ± 2 289 ± 2 288 ± 2 289 ± 2 288 ± 1
JetStreamConsumeWithFilters/N=3,R=3,storage=File/D=10000,DS=10,F=50,C=12-16 136 ± 2 136 ± 3 136 ± 2 136 ± 2 138 ± 2 135 ± 1 135 ± 2 136 ± 5 137 ± 1 135 ± 2

Contiguous Filtered Consumer throughput (op/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsumeFilteredContiguous/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory,SF-16 11.4k ± 0.0k 13.9k ± 3.8k 13.9k ± 3.9k 11.4k ± 0.1k 11.4k ± 0.0k 11.4k ± 0.0k 11.3k ± 0.0k 13.9k ± 3.8k 11.3k ± 0.0k 11.4k ± 0.0k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory-16 11.3k ± 0.0k 13.9k ± 3.8k 13.8k ± 3.9k 11.4k ± 0.0k 11.4k ± 0.0k 11.3k ± 0.0k 13.9k ± 3.9k 11.3k ± 0.0k 15.1k ± 2.6k 11.3k ± 0.0k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=File,SF-16 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 13.8k ± 3.8k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=File-16 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 13.7k ± 3.7k 11.2k ± 0.0k 11.2k ± 0.0k 13.6k ± 3.7k

Contiguous Filtered Consumer throughput (op/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamConsumeFilteredContiguous/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory,SF-16 11.4k ± 0.0k 13.9k ± 3.8k 13.9k ± 3.9k 11.4k ± 0.1k 11.4k ± 0.0k 11.4k ± 0.0k 11.3k ± 0.0k 13.9k ± 3.8k 11.3k ± 0.0k 11.4k ± 0.0k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory-16 11.3k ± 0.0k 13.9k ± 3.8k 13.8k ± 3.9k 11.4k ± 0.0k 11.4k ± 0.0k 11.3k ± 0.0k 13.9k ± 3.9k 11.3k ± 0.0k 15.1k ± 2.6k 11.3k ± 0.0k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=File,SF-16 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 13.8k ± 3.8k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=File-16 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 13.7k ± 3.7k 11.2k ± 0.0k 11.2k ± 0.0k 13.6k ± 3.7k

Single client Publish throughput(msg/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamPublish/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Sync-16 10.1k ± 0.1k 10.0k ± 0.3k 10.0k ± 0.1k 10.1k ± 0.1k 10.0k ± 0.2k 10.1k ± 0.1k 10.1k ± 0.2k 10.1k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:1000]-16 281k ± 3k 280k ± 3k 279k ± 3k 279k ± 4k 279k ± 1k 277k ± 3k 279k ± 3k 278k ± 1k 278k ± 3k 279k ± 3k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 281k ± 1k 281k ± 3k 282k ± 1k 280k ± 2k 279k ± 1k 281k ± 1k 282k ± 2k 281k ± 1k 282k ± 2k 280k ± 4k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 288k ± 1k 288k ± 1k 288k ± 2k 287k ± 1k 286k ± 2k 287k ± 1k 288k ± 0k 286k ± 1k 286k ± 3k 287k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.51k ± 0.17k 9.53k ± 0.11k 9.51k ± 0.12k 9.58k ± 0.10k 9.51k ± 0.15k 9.58k ± 0.10k 9.48k ± 0.05k 9.51k ± 0.15k 9.58k ± 0.08k 9.51k ± 0.05k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 180k ± 1k 181k ± 1k 178k ± 3k 179k ± 2k 179k ± 2k 178k ± 0k 179k ± 1k 178k ± 1k 176k ± 2k 179k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 185k ± 1k 186k ± 0k 185k ± 1k 184k ± 1k 183k ± 1k 182k ± 2k 184k ± 0k 183k ± 1k 182k ± 2k 184k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 186k ± 1k 188k ± 1k 186k ± 0k 186k ± 2k 186k ± 1k 185k ± 2k 184k ± 1k 185k ± 1k 184k ± 2k 185k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Sync-16 10.1k ± 0.1k 10.0k ± 0.2k 10.1k ± 0.1k 10.1k ± 0.3k 10.1k ± 0.1k 10.1k ± 0.1k 10.1k ± 0.1k 10.0k ± 0.2k 10.0k ± 0.1k 10.2k ± 0.1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:1000]-16 279k ± 2k 282k ± 1k 278k ± 2k 280k ± 2k 276k ± 3k 276k ± 2k 278k ± 1k 279k ± 1k 277k ± 4k 279k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 282k ± 2k 283k ± 3k 281k ± 3k 282k ± 1k 280k ± 2k 282k ± 1k 283k ± 2k 280k ± 2k 280k ± 1k 280k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 288k ± 2k 289k ± 4k 287k ± 4k 287k ± 3k 286k ± 3k 287k ± 1k 287k ± 1k 286k ± 1k 286k ± 2k 285k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.46k ± 0.16k 9.52k ± 0.05k 9.54k ± 0.06k 9.67k ± 0.05k 9.59k ± 0.08k 9.51k ± 0.18k 9.55k ± 0.08k 9.49k ± 0.19k 9.43k ± 0.16k 9.48k ± 0.06k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 179k ± 0k 181k ± 1k 179k ± 2k 180k ± 1k 178k ± 3k 178k ± 0k 171k ± 8k 178k ± 1k 178k ± 2k 178k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 184k ± 1k 186k ± 1k 185k ± 1k 184k ± 1k 183k ± 2k 183k ± 1k 183k ± 1k 184k ± 2k 183k ± 2k 184k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 185k ± 2k 187k ± 1k 186k ± 1k 185k ± 3k 185k ± 2k 184k ± 3k 186k ± 0k 184k ± 2k 185k ± 2k 186k ± 0k

Single client Publish throughput(byte/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamPublish/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Sync-16 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:1000]-16 2.81MB/s ± 0.03MB/s 2.80MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.79MB/s ± 0.04MB/s 2.79MB/s ± 0.00MB/s 2.77MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.78MB/s ± 0.01MB/s 2.78MB/s ± 0.03MB/s 2.79MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.03MB/s 2.82MB/s ± 0.01MB/s 2.80MB/s ± 0.03MB/s 2.79MB/s ± 0.01MB/s 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.01MB/s 2.80MB/s ± 0.04MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 2.88MB/s ± 0.01MB/s 2.88MB/s ± 0.02MB/s 2.88MB/s ± 0.02MB/s 2.87MB/s ± 0.00MB/s 2.86MB/s ± 0.01MB/s 2.88MB/s ± 0.01MB/s 2.88MB/s ± 0.00MB/s 2.86MB/s ± 0.02MB/s 2.85MB/s ± 0.00MB/s 2.86MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.74MB/s ± 0.17MB/s 9.76MB/s ± 0.12MB/s 9.74MB/s ± 0.12MB/s 9.81MB/s ± 0.10MB/s 9.74MB/s ± 0.16MB/s 9.81MB/s ± 0.10MB/s 9.71MB/s ± 0.05MB/s 9.74MB/s ± 0.15MB/s 9.81MB/s ± 0.09MB/s 9.74MB/s ± 0.05MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 184MB/s ± 1MB/s 185MB/s ± 1MB/s 182MB/s ± 3MB/s 183MB/s ± 2MB/s 183MB/s ± 2MB/s 182MB/s ± 0MB/s 183MB/s ± 1MB/s 182MB/s ± 1MB/s 181MB/s ± 2MB/s 183MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 189MB/s ± 1MB/s 190MB/s ± 0MB/s 189MB/s ± 1MB/s 188MB/s ± 1MB/s 188MB/s ± 1MB/s 187MB/s ± 2MB/s 188MB/s ± 0MB/s 188MB/s ± 1MB/s 187MB/s ± 3MB/s 188MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 190MB/s ± 1MB/s 192MB/s ± 1MB/s 191MB/s ± 0MB/s 190MB/s ± 2MB/s 190MB/s ± 1MB/s 190MB/s ± 2MB/s 189MB/s ± 1MB/s 189MB/s ± 1MB/s 189MB/s ± 2MB/s 190MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Sync-16 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:1000]-16 2.79MB/s ± 0.02MB/s 2.82MB/s ± 0.01MB/s 2.78MB/s ± 0.02MB/s 2.80MB/s ± 0.01MB/s 2.76MB/s ± 0.03MB/s 2.76MB/s ± 0.03MB/s 2.78MB/s ± 0.01MB/s 2.78MB/s ± 0.01MB/s 2.77MB/s ± 0.04MB/s 2.79MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 2.82MB/s ± 0.02MB/s 2.83MB/s ± 0.03MB/s 2.81MB/s ± 0.03MB/s 2.82MB/s ± 0.01MB/s 2.80MB/s ± 0.02MB/s 2.82MB/s ± 0.01MB/s 2.83MB/s ± 0.01MB/s 2.81MB/s ± 0.02MB/s 2.80MB/s ± 0.01MB/s 2.80MB/s ± 0.01MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 2.88MB/s ± 0.02MB/s 2.89MB/s ± 0.04MB/s 2.87MB/s ± 0.04MB/s 2.87MB/s ± 0.02MB/s 2.86MB/s ± 0.03MB/s 2.87MB/s ± 0.01MB/s 2.87MB/s ± 0.01MB/s 2.86MB/s ± 0.02MB/s 2.86MB/s ± 0.01MB/s 2.85MB/s ± 0.03MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.69MB/s ± 0.16MB/s 9.74MB/s ± 0.06MB/s 9.77MB/s ± 0.06MB/s 9.91MB/s ± 0.04MB/s 9.82MB/s ± 0.08MB/s 9.73MB/s ± 0.19MB/s 9.78MB/s ± 0.08MB/s 9.71MB/s ± 0.20MB/s 9.66MB/s ± 0.16MB/s 9.71MB/s ± 0.06MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 183MB/s ± 0MB/s 185MB/s ± 1MB/s 184MB/s ± 2MB/s 184MB/s ± 1MB/s 182MB/s ± 3MB/s 182MB/s ± 0MB/s 175MB/s ± 8MB/s 182MB/s ± 1MB/s 183MB/s ± 2MB/s 183MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 188MB/s ± 1MB/s 190MB/s ± 2MB/s 189MB/s ± 1MB/s 189MB/s ± 1MB/s 187MB/s ± 2MB/s 188MB/s ± 1MB/s 188MB/s ± 1MB/s 188MB/s ± 2MB/s 188MB/s ± 2MB/s 188MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 190MB/s ± 2MB/s 191MB/s ± 1MB/s 191MB/s ± 1MB/s 189MB/s ± 3MB/s 189MB/s ± 2MB/s 189MB/s ± 3MB/s 190MB/s ± 0MB/s 189MB/s ± 2MB/s 190MB/s ± 2MB/s 191MB/s ± 0MB/s

Single client Publish throughput(msg/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamPublish/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Sync-16 10.1k ± 0.1k 10.0k ± 0.3k 10.0k ± 0.1k 10.1k ± 0.1k 10.0k ± 0.2k 10.1k ± 0.1k 10.1k ± 0.2k 10.1k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:1000]-16 281k ± 3k 280k ± 3k 279k ± 3k 279k ± 4k 279k ± 1k 277k ± 3k 279k ± 3k 278k ± 1k 278k ± 3k 279k ± 3k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 281k ± 1k 281k ± 3k 282k ± 1k 280k ± 2k 279k ± 1k 281k ± 1k 282k ± 2k 281k ± 1k 282k ± 2k 280k ± 4k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 288k ± 1k 288k ± 1k 288k ± 2k 287k ± 1k 286k ± 2k 287k ± 1k 288k ± 0k 286k ± 1k 286k ± 3k 287k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.51k ± 0.17k 9.53k ± 0.11k 9.51k ± 0.12k 9.58k ± 0.10k 9.51k ± 0.15k 9.58k ± 0.10k 9.48k ± 0.05k 9.51k ± 0.15k 9.58k ± 0.08k 9.51k ± 0.05k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 180k ± 1k 181k ± 1k 178k ± 3k 179k ± 2k 179k ± 2k 178k ± 0k 179k ± 1k 178k ± 1k 176k ± 2k 179k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 185k ± 1k 186k ± 0k 185k ± 1k 184k ± 1k 183k ± 1k 182k ± 2k 184k ± 0k 183k ± 1k 182k ± 2k 184k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 186k ± 1k 188k ± 1k 186k ± 0k 186k ± 2k 186k ± 1k 185k ± 2k 184k ± 1k 185k ± 1k 184k ± 2k 185k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Sync-16 10.1k ± 0.1k 10.0k ± 0.2k 10.1k ± 0.1k 10.1k ± 0.3k 10.1k ± 0.1k 10.1k ± 0.1k 10.1k ± 0.1k 10.0k ± 0.2k 10.0k ± 0.1k 10.2k ± 0.1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:1000]-16 279k ± 2k 282k ± 1k 278k ± 2k 280k ± 2k 276k ± 3k 276k ± 2k 278k ± 1k 279k ± 1k 277k ± 4k 279k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 282k ± 2k 283k ± 3k 281k ± 3k 282k ± 1k 280k ± 2k 282k ± 1k 283k ± 2k 280k ± 2k 280k ± 1k 280k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 288k ± 2k 289k ± 4k 287k ± 4k 287k ± 3k 286k ± 3k 287k ± 1k 287k ± 1k 286k ± 1k 286k ± 2k 285k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.46k ± 0.16k 9.52k ± 0.05k 9.54k ± 0.06k 9.67k ± 0.05k 9.59k ± 0.08k 9.51k ± 0.18k 9.55k ± 0.08k 9.49k ± 0.19k 9.43k ± 0.16k 9.48k ± 0.06k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 179k ± 0k 181k ± 1k 179k ± 2k 180k ± 1k 178k ± 3k 178k ± 0k 171k ± 8k 178k ± 1k 178k ± 2k 178k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 184k ± 1k 186k ± 1k 185k ± 1k 184k ± 1k 183k ± 2k 183k ± 1k 183k ± 1k 184k ± 2k 183k ± 2k 184k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 185k ± 2k 187k ± 1k 186k ± 1k 185k ± 3k 185k ± 2k 184k ± 3k 186k ± 0k 184k ± 2k 185k ± 2k 186k ± 0k

Single client Publish throughput(byte/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamPublish/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Sync-16 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:1000]-16 2.81MB/s ± 0.03MB/s 2.80MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.79MB/s ± 0.04MB/s 2.79MB/s ± 0.00MB/s 2.77MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.78MB/s ± 0.01MB/s 2.78MB/s ± 0.03MB/s 2.79MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.03MB/s 2.82MB/s ± 0.01MB/s 2.80MB/s ± 0.03MB/s 2.79MB/s ± 0.01MB/s 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.01MB/s 2.80MB/s ± 0.04MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 2.88MB/s ± 0.01MB/s 2.88MB/s ± 0.02MB/s 2.88MB/s ± 0.02MB/s 2.87MB/s ± 0.00MB/s 2.86MB/s ± 0.01MB/s 2.88MB/s ± 0.01MB/s 2.88MB/s ± 0.00MB/s 2.86MB/s ± 0.02MB/s 2.85MB/s ± 0.00MB/s 2.86MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.74MB/s ± 0.17MB/s 9.76MB/s ± 0.12MB/s 9.74MB/s ± 0.12MB/s 9.81MB/s ± 0.10MB/s 9.74MB/s ± 0.16MB/s 9.81MB/s ± 0.10MB/s 9.71MB/s ± 0.05MB/s 9.74MB/s ± 0.15MB/s 9.81MB/s ± 0.09MB/s 9.74MB/s ± 0.05MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 184MB/s ± 1MB/s 185MB/s ± 1MB/s 182MB/s ± 3MB/s 183MB/s ± 2MB/s 183MB/s ± 2MB/s 182MB/s ± 0MB/s 183MB/s ± 1MB/s 182MB/s ± 1MB/s 181MB/s ± 2MB/s 183MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 189MB/s ± 1MB/s 190MB/s ± 0MB/s 189MB/s ± 1MB/s 188MB/s ± 1MB/s 188MB/s ± 1MB/s 187MB/s ± 2MB/s 188MB/s ± 0MB/s 188MB/s ± 1MB/s 187MB/s ± 3MB/s 188MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 190MB/s ± 1MB/s 192MB/s ± 1MB/s 191MB/s ± 0MB/s 190MB/s ± 2MB/s 190MB/s ± 1MB/s 190MB/s ± 2MB/s 189MB/s ± 1MB/s 189MB/s ± 1MB/s 189MB/s ± 2MB/s 190MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Sync-16 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s 100kB/s ± 0kB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:1000]-16 2.79MB/s ± 0.02MB/s 2.82MB/s ± 0.01MB/s 2.78MB/s ± 0.02MB/s 2.80MB/s ± 0.01MB/s 2.76MB/s ± 0.03MB/s 2.76MB/s ± 0.03MB/s 2.78MB/s ± 0.01MB/s 2.78MB/s ± 0.01MB/s 2.77MB/s ± 0.04MB/s 2.79MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 2.82MB/s ± 0.02MB/s 2.83MB/s ± 0.03MB/s 2.81MB/s ± 0.03MB/s 2.82MB/s ± 0.01MB/s 2.80MB/s ± 0.02MB/s 2.82MB/s ± 0.01MB/s 2.83MB/s ± 0.01MB/s 2.81MB/s ± 0.02MB/s 2.80MB/s ± 0.01MB/s 2.80MB/s ± 0.01MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 2.88MB/s ± 0.02MB/s 2.89MB/s ± 0.04MB/s 2.87MB/s ± 0.04MB/s 2.87MB/s ± 0.02MB/s 2.86MB/s ± 0.03MB/s 2.87MB/s ± 0.01MB/s 2.87MB/s ± 0.01MB/s 2.86MB/s ± 0.02MB/s 2.86MB/s ± 0.01MB/s 2.85MB/s ± 0.03MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.69MB/s ± 0.16MB/s 9.74MB/s ± 0.06MB/s 9.77MB/s ± 0.06MB/s 9.91MB/s ± 0.04MB/s 9.82MB/s ± 0.08MB/s 9.73MB/s ± 0.19MB/s 9.78MB/s ± 0.08MB/s 9.71MB/s ± 0.20MB/s 9.66MB/s ± 0.16MB/s 9.71MB/s ± 0.06MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 183MB/s ± 0MB/s 185MB/s ± 1MB/s 184MB/s ± 2MB/s 184MB/s ± 1MB/s 182MB/s ± 3MB/s 182MB/s ± 0MB/s 175MB/s ± 8MB/s 182MB/s ± 1MB/s 183MB/s ± 2MB/s 183MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 188MB/s ± 1MB/s 190MB/s ± 2MB/s 189MB/s ± 1MB/s 189MB/s ± 1MB/s 187MB/s ± 2MB/s 188MB/s ± 1MB/s 188MB/s ± 1MB/s 188MB/s ± 2MB/s 188MB/s ± 2MB/s 188MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 190MB/s ± 2MB/s 191MB/s ± 1MB/s 191MB/s ± 1MB/s 189MB/s ± 3MB/s 189MB/s ± 2MB/s 189MB/s ± 3MB/s 190MB/s ± 0MB/s 189MB/s ± 2MB/s 190MB/s ± 2MB/s 191MB/s ± 0MB/s

Concurrent Publish throughput (msg/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamPublishConcurrent/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamPublishConcurrent/N=3,R=3/msgSz=10b/pubs=12-16 70.2k ± 0.1k 70.3k ± 0.1k 68.8k ± 1.6k 70.1k ± 0.2k 70.0k ± 0.1k 68.4k ± 1.9k 70.3k ± 0.2k 68.9k ± 1.2k 69.8k ± 0.1k 67.2k ± 2.8k
JetStreamPublishConcurrent/N=3,R=3/msgSz=1024b/pubs=12-16 59.1k ± 1.7k 59.9k ± 0.6k 58.4k ± 2.1k 60.3k ± 0.2k 59.9k ± 0.8k 60.1k ± 0.5k 58.3k ± 2.1k 59.8k ± 0.6k 60.1k ± 0.2k 60.1k ± 0.5k
JetStreamPublishConcurrent/N=3,R=3/msgSz=102400b/pubs=12-16 1.72k ± 0.57k 1.56k ± 0.00k 2.20k ± 0.02k 1.80k ± 0.43k 1.54k ± 0.02k 1.81k ± 0.40k 2.28k ± 0.06k 1.96k ± 0.38k 1.54k ± 0.03k 1.99k ± 0.36k
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=10b/pubs=12-16 70.2k ± 0.1k 70.2k ± 0.0k 70.1k ± 0.1k 70.3k ± 0.3k 69.5k ± 0.6k 69.9k ± 0.1k 70.2k ± 0.2k 69.3k ± 0.9k 69.8k ± 0.2k 70.1k ± 0.1k
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=1024b/pubs=12-16 60.4k ± 0.3k 60.4k ± 0.3k 59.7k ± 0.8k 60.4k ± 0.3k 59.6k ± 0.9k 59.3k ± 0.9k 59.9k ± 0.3k 60.3k ± 0.2k 59.9k ± 0.1k 59.9k ± 0.7k
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=102400b/pubs=12-16 2.04k ± 0.18k 1.57k ± 0.01k 1.57k ± 0.01k 1.80k ± 0.39k 1.81k ± 0.45k 1.82k ± 0.40k 1.56k ± 0.02k 1.83k ± 0.46k 1.83k ± 0.46k 2.00k ± 0.36k

Concurrent Publish throughput (byte/s)

Error bars represent 90% confidence interval, benchmarks filter: 'JetStreamPublishConcurrent/.*'

Show results table
main [48a757b] main [425cf16] main [12bc38e] main [d1bf5a7] main [91602f9] main [c739352] main [d897a1a] main [7885ebd] main [192d2bf] main [85594c8]
JetStreamPublishConcurrent/N=3,R=3/msgSz=10b/pubs=12-16 700kB/s ± 0kB/s 700kB/s ± 0kB/s 688kB/s ± 12kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 684kB/s ± 16kB/s 700kB/s ± 0kB/s 688kB/s ± 12kB/s 700kB/s ± 0kB/s 672kB/s ± 28kB/s
JetStreamPublishConcurrent/N=3,R=3/msgSz=1024b/pubs=12-16 60.5MB/s ± 1.8MB/s 61.4MB/s ± 0.6MB/s 59.8MB/s ± 2.1MB/s 61.7MB/s ± 0.2MB/s 61.3MB/s ± 0.8MB/s 61.5MB/s ± 0.5MB/s 59.7MB/s ± 2.2MB/s 61.3MB/s ± 0.6MB/s 61.5MB/s ± 0.2MB/s 61.6MB/s ± 0.5MB/s
JetStreamPublishConcurrent/N=3,R=3/msgSz=102400b/pubs=12-16 161MB/s ± 4MB/s 160MB/s ± 0MB/s 225MB/s ± 2MB/s 184MB/s ± 44MB/s 158MB/s ± 2MB/s 185MB/s ± 41MB/s 233MB/s ± 7MB/s 201MB/s ± 39MB/s 158MB/s ± 3MB/s 204MB/s ± 37MB/s
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=10b/pubs=12-16 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 702kB/s ± 7kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=1024b/pubs=12-16 61.9MB/s ± 0.3MB/s 61.8MB/s ± 0.3MB/s 61.1MB/s ± 0.8MB/s 61.8MB/s ± 0.3MB/s 61.0MB/s ± 0.9MB/s 60.7MB/s ± 0.9MB/s 61.3MB/s ± 0.3MB/s 61.7MB/s ± 0.2MB/s 61.4MB/s ± 0.1MB/s 61.3MB/s ± 0.7MB/s
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=102400b/pubs=12-16 209MB/s ± 18MB/s 161MB/s ± 1MB/s 161MB/s ± 2MB/s 184MB/s ± 40MB/s 185MB/s ± 46MB/s 187MB/s ± 41MB/s 160MB/s ± 2MB/s 188MB/s ± 47MB/s 188MB/s ± 47MB/s 205MB/s ± 37MB/s