Trend: JetStream - Recent commits to 'main' branch

Show jobs details
Job Source Filter Repetitions Go Worker Job Info
f444b591-8f97-49fc-b54c-0787f16ede45 main
https://github.com/nats-io/nats-server.git
(b94011e1ce3f8c937626f8ee75b892a9f315aabe)		 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-30 00:00:20 +0000 UTC
be7362c0-1ec9-4224-90cd-5f6bec94f883 main
https://github.com/nats-io/nats-server.git
(5d63c16bae7c67cab95a94657f6c64996011b910)		 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-31 00:00:15 +0000 UTC
aa38ac52-5b64-499d-ac91-c8f6d0c673ea main
https://github.com/nats-io/nats-server.git
(e2661b5c2825e94e01b0c4ba78c299a69e9d1c61)		 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-11-03 00:00:27 +0000 UTC
0f01ce55-9b4d-4bf1-83ba-3799e55b794b main
https://github.com/nats-io/nats-server.git
(48a4477c230a08c45ac64800abe7fa256f228b23)		 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-11-04 00:00:19 +0000 UTC
3636754c-f908-42ba-a65f-16ec900d7a43 main
https://github.com/nats-io/nats-server.git
(3e60436763487712a79b2cf39dbb230f0e23e333)		 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-11-05 00:00:12 +0000 UTC
0eea8d5b-9351-47ac-9ee3-3419b6e28a6c main
https://github.com/nats-io/nats-server.git
(60a276b875f9ab4e8caa3303b66147d57441aa09)		 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-11-06 00:00:13 +0000 UTC
4ec29193-14f6-43f8-9cac-9fb2f9ec385e main
https://github.com/nats-io/nats-server.git
(a098c7e1c49d3f4d1eddfc97f73a099b88ec4b4b)		 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-11-07 00:00:10 +0000 UTC
7d713460-46a0-4d86-92db-2c035e257ffb main
https://github.com/nats-io/nats-server.git
(33952ebee282261769b0f7df548cc4f98e1a32b7)		 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-11-10 00:00:26 +0000 UTC
7946e09a-f25b-4bbe-b1eb-b5288f8a498f main
https://github.com/nats-io/nats-server.git
(395a18e45356cf927b35184164b447600b4cad94)		 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-11-11 00:00:25 +0000 UTC
a4abd092-0074-49e5-8967-92cb0f7d3dd2 main
https://github.com/nats-io/nats-server.git
(ed493ec938c33568192675fdacab0de30e929ba1)		 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-11-12 00:00:16 +0000 UTC

Push Consumer throughput (msg/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 549k ± 36k 531k ± 39k 535k ± 52k 539k ± 43k 579k ± 3k 527k ± 43k 546k ± 30k 537k ± 41k 585k ± 2k 513k ± 11k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 589k ± 72k 557k ± 96k 569k ± 94k 588k ± 81k 590k ± 77k 535k ± 2k 537k ± 11k 583k ± 77k 541k ± 11k 602k ± 86k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 1.07M ± 0.06M 1.06M ± 0.07M 1.08M ± 0.06M 1.04M ± 0.03M 1.10M ± 0.04M 1.14M ± 0.01M 1.09M ± 0.05M 1.02M ± 0.02M 1.08M ± 0.05M 1.09M ± 0.08M
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 354k ± 55k 362k ± 47k 382k ± 61k 368k ± 69k 385k ± 5k 404k ± 39k 400k ± 43k 377k ± 59k 404k ± 44k 397k ± 9k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 422k ± 32k 403k ± 2k 415k ± 37k 430k ± 23k 440k ± 19k 396k ± 52k 421k ± 32k 422k ± 29k 403k ± 58k 412k ± 3k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 482k ± 61k 497k ± 46k 457k ± 0k 464k ± 71k 499k ± 40k 458k ± 1k 455k ± 2k 502k ± 34k 443k ± 90k 419k ± 36k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 343k ± 8k 283k ± 63k 301k ± 59k 295k ± 48k 251k ± 96k 320k ± 26k 295k ± 60k 321k ± 33k 324k ± 25k 292k ± 54k

Push Consumer throughput (byte/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 5.50MB/s ± 0.36MB/s 5.31MB/s ± 0.38MB/s 5.35MB/s ± 0.52MB/s 5.39MB/s ± 0.44MB/s 5.79MB/s ± 0.04MB/s 5.27MB/s ± 0.42MB/s 5.46MB/s ± 0.30MB/s 5.37MB/s ± 0.41MB/s 5.86MB/s ± 0.02MB/s 5.14MB/s ± 0.11MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 5.90MB/s ± 0.72MB/s 5.57MB/s ± 0.96MB/s 5.69MB/s ± 0.94MB/s 5.88MB/s ± 0.81MB/s 5.90MB/s ± 0.76MB/s 5.35MB/s ± 0.01MB/s 5.37MB/s ± 0.10MB/s 5.83MB/s ± 0.77MB/s 5.41MB/s ± 0.10MB/s 6.02MB/s ± 0.86MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 10.7MB/s ± 0.6MB/s 10.6MB/s ± 0.7MB/s 10.8MB/s ± 0.6MB/s 10.4MB/s ± 0.3MB/s 11.0MB/s ± 0.4MB/s 11.2MB/s ± 0.4MB/s 10.9MB/s ± 0.5MB/s 10.2MB/s ± 0.2MB/s 10.8MB/s ± 0.5MB/s 10.9MB/s ± 0.8MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 3.54MB/s ± 0.55MB/s 3.62MB/s ± 0.47MB/s 3.82MB/s ± 0.61MB/s 3.68MB/s ± 0.69MB/s 3.86MB/s ± 0.05MB/s 4.05MB/s ± 0.39MB/s 4.00MB/s ± 0.43MB/s 3.77MB/s ± 0.59MB/s 4.04MB/s ± 0.44MB/s 3.68MB/s ± 0.38MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 433MB/s ± 33MB/s 413MB/s ± 2MB/s 425MB/s ± 38MB/s 440MB/s ± 23MB/s 450MB/s ± 19MB/s 406MB/s ± 53MB/s 431MB/s ± 32MB/s 433MB/s ± 30MB/s 412MB/s ± 59MB/s 422MB/s ± 3MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 494MB/s ± 63MB/s 509MB/s ± 47MB/s 468MB/s ± 0MB/s 475MB/s ± 73MB/s 511MB/s ± 41MB/s 469MB/s ± 1MB/s 466MB/s ± 2MB/s 514MB/s ± 35MB/s 453MB/s ± 92MB/s 429MB/s ± 37MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 313MB/s ± 47MB/s 290MB/s ± 65MB/s 308MB/s ± 61MB/s 302MB/s ± 49MB/s 257MB/s ± 98MB/s 328MB/s ± 27MB/s 302MB/s ± 62MB/s 328MB/s ± 34MB/s 332MB/s ± 25MB/s 299MB/s ± 55MB/s

Pull Consumer throughput (msg/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 245k ± 33k 212k ± 5k 226k ± 41k 248k ± 32k 275k ± 6k 248k ± 30k 236k ± 36k 224k ± 49k 217k ± 2k 234k ± 44k
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 310k ± 2k 311k ± 2k 312k ± 2k 310k ± 2k 311k ± 2k 311k ± 3k 309k ± 1k 312k ± 3k 315k ± 2k 312k ± 1k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 191k ± 3k 199k ± 42k 193k ± 1k 191k ± 2k 212k ± 32k 190k ± 3k 221k ± 21k 212k ± 30k 201k ± 35k 190k ± 2k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 263k ± 6k 267k ± 3k 269k ± 4k 269k ± 4k 301k ± 36k 271k ± 1k 291k ± 41k 269k ± 1k 296k ± 33k 269k ± 2k

Pull Consumer throughput (byte/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 2.45MB/s ± 0.34MB/s 2.12MB/s ± 0.05MB/s 2.26MB/s ± 0.42MB/s 2.48MB/s ± 0.32MB/s 2.75MB/s ± 0.06MB/s 2.48MB/s ± 0.31MB/s 2.36MB/s ± 0.36MB/s 2.12MB/s ± 0.04MB/s 2.13MB/s ± 0.05MB/s 2.34MB/s ± 0.44MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 3.10MB/s ± 0.02MB/s 3.11MB/s ± 0.02MB/s 3.12MB/s ± 0.02MB/s 3.10MB/s ± 0.02MB/s 3.11MB/s ± 0.02MB/s 3.11MB/s ± 0.03MB/s 3.08MB/s ± 0.02MB/s 3.12MB/s ± 0.03MB/s 3.15MB/s ± 0.01MB/s 3.12MB/s ± 0.01MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 195MB/s ± 3MB/s 193MB/s ± 4MB/s 198MB/s ± 1MB/s 196MB/s ± 2MB/s 217MB/s ± 33MB/s 195MB/s ± 3MB/s 226MB/s ± 22MB/s 217MB/s ± 31MB/s 197MB/s ± 3MB/s 195MB/s ± 2MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 269MB/s ± 6MB/s 274MB/s ± 3MB/s 276MB/s ± 4MB/s 275MB/s ± 4MB/s 309MB/s ± 37MB/s 278MB/s ± 1MB/s 298MB/s ± 42MB/s 276MB/s ± 1MB/s 303MB/s ± 34MB/s 275MB/s ± 2MB/s

Consume throughput (msg/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 549k ± 36k 531k ± 39k 535k ± 52k 539k ± 43k 579k ± 3k 527k ± 43k 546k ± 30k 537k ± 41k 585k ± 2k 513k ± 11k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 589k ± 72k 557k ± 96k 569k ± 94k 588k ± 81k 590k ± 77k 535k ± 2k 537k ± 11k 583k ± 77k 541k ± 11k 602k ± 86k
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 1.07M ± 0.06M 1.06M ± 0.07M 1.08M ± 0.06M 1.04M ± 0.03M 1.10M ± 0.04M 1.14M ± 0.01M 1.09M ± 0.05M 1.02M ± 0.02M 1.08M ± 0.05M 1.09M ± 0.08M
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 354k ± 55k 362k ± 47k 382k ± 61k 368k ± 69k 385k ± 5k 404k ± 39k 400k ± 43k 377k ± 59k 404k ± 44k 397k ± 9k
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 245k ± 33k 212k ± 5k 226k ± 41k 248k ± 32k 275k ± 6k 248k ± 30k 236k ± 36k 224k ± 49k 217k ± 2k 234k ± 44k
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 310k ± 2k 311k ± 2k 312k ± 2k 310k ± 2k 311k ± 2k 311k ± 3k 309k ± 1k 312k ± 3k 315k ± 2k 312k ± 1k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 422k ± 32k 403k ± 2k 415k ± 37k 430k ± 23k 440k ± 19k 396k ± 52k 421k ± 32k 422k ± 29k 403k ± 58k 412k ± 3k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 482k ± 61k 497k ± 46k 457k ± 0k 464k ± 71k 499k ± 40k 458k ± 1k 455k ± 2k 502k ± 34k 443k ± 90k 419k ± 36k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 343k ± 8k 283k ± 63k 301k ± 59k 295k ± 48k 251k ± 96k 320k ± 26k 295k ± 60k 321k ± 33k 324k ± 25k 292k ± 54k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 191k ± 3k 199k ± 42k 193k ± 1k 191k ± 2k 212k ± 32k 190k ± 3k 221k ± 21k 212k ± 30k 201k ± 35k 190k ± 2k
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 263k ± 6k 267k ± 3k 269k ± 4k 269k ± 4k 301k ± 36k 271k ± 1k 291k ± 41k 269k ± 1k 296k ± 33k 269k ± 2k

Consume throughput (byte/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Sync,Ephemeral]-16 5.50MB/s ± 0.36MB/s 5.31MB/s ± 0.38MB/s 5.35MB/s ± 0.52MB/s 5.39MB/s ± 0.44MB/s 5.79MB/s ± 0.04MB/s 5.27MB/s ± 0.42MB/s 5.46MB/s ± 0.30MB/s 5.37MB/s ± 0.41MB/s 5.86MB/s ± 0.02MB/s 5.14MB/s ± 0.11MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ephemeral]-16 5.90MB/s ± 0.72MB/s 5.57MB/s ± 0.96MB/s 5.69MB/s ± 0.94MB/s 5.88MB/s ± 0.81MB/s 5.90MB/s ± 0.76MB/s 5.35MB/s ± 0.01MB/s 5.37MB/s ± 0.10MB/s 5.83MB/s ± 0.77MB/s 5.41MB/s ± 0.10MB/s 6.02MB/s ± 0.86MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Ordered]-16 10.7MB/s ± 0.6MB/s 10.6MB/s ± 0.7MB/s 10.8MB/s ± 0.6MB/s 10.4MB/s ± 0.3MB/s 11.0MB/s ± 0.4MB/s 11.2MB/s ± 0.4MB/s 10.9MB/s ± 0.5MB/s 10.2MB/s ± 0.2MB/s 10.8MB/s ± 0.5MB/s 10.9MB/s ± 0.8MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PUSH[Async,Durable]-16 3.54MB/s ± 0.55MB/s 3.62MB/s ± 0.47MB/s 3.82MB/s ± 0.61MB/s 3.68MB/s ± 0.69MB/s 3.86MB/s ± 0.05MB/s 4.05MB/s ± 0.39MB/s 4.00MB/s ± 0.43MB/s 3.77MB/s ± 0.59MB/s 4.04MB/s ± 0.44MB/s 3.68MB/s ± 0.38MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Durable]-16 2.45MB/s ± 0.34MB/s 2.12MB/s ± 0.05MB/s 2.26MB/s ± 0.42MB/s 2.48MB/s ± 0.32MB/s 2.75MB/s ± 0.06MB/s 2.48MB/s ± 0.31MB/s 2.36MB/s ± 0.36MB/s 2.12MB/s ± 0.04MB/s 2.13MB/s ± 0.05MB/s 2.34MB/s ± 0.44MB/s
JetStreamConsume/N=3,R=3,MsgSz=10b/PULL[Ephemeral]-16 3.10MB/s ± 0.02MB/s 3.11MB/s ± 0.02MB/s 3.12MB/s ± 0.02MB/s 3.10MB/s ± 0.02MB/s 3.11MB/s ± 0.02MB/s 3.11MB/s ± 0.03MB/s 3.08MB/s ± 0.02MB/s 3.12MB/s ± 0.03MB/s 3.15MB/s ± 0.01MB/s 3.12MB/s ± 0.01MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Sync,Ephemeral]-16 433MB/s ± 33MB/s 413MB/s ± 2MB/s 425MB/s ± 38MB/s 440MB/s ± 23MB/s 450MB/s ± 19MB/s 406MB/s ± 53MB/s 431MB/s ± 32MB/s 433MB/s ± 30MB/s 412MB/s ± 59MB/s 422MB/s ± 3MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Ephemeral]-16 494MB/s ± 63MB/s 509MB/s ± 47MB/s 468MB/s ± 0MB/s 475MB/s ± 73MB/s 511MB/s ± 41MB/s 469MB/s ± 1MB/s 466MB/s ± 2MB/s 514MB/s ± 35MB/s 453MB/s ± 92MB/s 429MB/s ± 37MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PUSH[Async,Durable]-16 313MB/s ± 47MB/s 290MB/s ± 65MB/s 308MB/s ± 61MB/s 302MB/s ± 49MB/s 257MB/s ± 98MB/s 328MB/s ± 27MB/s 302MB/s ± 62MB/s 328MB/s ± 34MB/s 332MB/s ± 25MB/s 299MB/s ± 55MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Durable]-16 195MB/s ± 3MB/s 193MB/s ± 4MB/s 198MB/s ± 1MB/s 196MB/s ± 2MB/s 217MB/s ± 33MB/s 195MB/s ± 3MB/s 226MB/s ± 22MB/s 217MB/s ± 31MB/s 197MB/s ± 3MB/s 195MB/s ± 2MB/s
JetStreamConsume/N=3,R=3,MsgSz=1024b/PULL[Ephemeral]-16 269MB/s ± 6MB/s 274MB/s ± 3MB/s 276MB/s ± 4MB/s 275MB/s ± 4MB/s 309MB/s ± 37MB/s 278MB/s ± 1MB/s 298MB/s ± 42MB/s 276MB/s ± 1MB/s 303MB/s ± 34MB/s 275MB/s ± 2MB/s

Filtered Consumer throughput (op/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsumeWithFilters/N=3,R=3,storage=Memory/D=10000,DS=10,F=50,C=12-16 289 ± 2 287 ± 1 291 ± 1 290 ± 2 289 ± 1 289 ± 1 290 ± 2 288 ± 2 288 ± 5 290 ± 2
JetStreamConsumeWithFilters/N=3,R=3,storage=File/D=10000,DS=10,F=50,C=12-16 136 ± 3 137 ± 2 136 ± 1 135 ± 4 135 ± 2 137 ± 2 134 ± 4 138 ± 1 137 ± 3 136 ± 1

Filtered Consumer throughput (op/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsumeWithFilters/N=3,R=3,storage=Memory/D=10000,DS=10,F=50,C=12-16 289 ± 2 287 ± 1 291 ± 1 290 ± 2 289 ± 1 289 ± 1 290 ± 2 288 ± 2 288 ± 5 290 ± 2
JetStreamConsumeWithFilters/N=3,R=3,storage=File/D=10000,DS=10,F=50,C=12-16 136 ± 3 137 ± 2 136 ± 1 135 ± 4 135 ± 2 137 ± 2 134 ± 4 138 ± 1 137 ± 3 136 ± 1

Contiguous Filtered Consumer throughput (op/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory,SF-16 13.8k ± 3.8k 11.3k ± 0.0k 11.3k ± 0.0k 11.4k ± 0.0k 13.8k ± 3.8k 13.9k ± 3.9k 11.3k ± 0.0k 11.3k ± 0.0k 11.4k ± 0.0k 11.3k ± 0.1k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory-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 13.8k ± 3.8k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=File,SF-16 11.2k ± 0.0k 11.2k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.2k ± 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 13.6k ± 3.7k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.1k ± 0.0k

Contiguous Filtered Consumer throughput (op/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory,SF-16 13.8k ± 3.8k 11.3k ± 0.0k 11.3k ± 0.0k 11.4k ± 0.0k 13.8k ± 3.8k 13.9k ± 3.9k 11.3k ± 0.0k 11.3k ± 0.0k 11.4k ± 0.0k 11.3k ± 0.1k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=Memory-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 13.8k ± 3.8k
JetStreamConsumeFilteredContiguous/N=3,R=3,storage=File,SF-16 11.2k ± 0.0k 11.2k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.3k ± 0.0k 11.2k ± 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 13.6k ± 3.7k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.2k ± 0.0k 11.1k ± 0.0k

Single client Publish throughput(msg/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Sync-16 10.0k ± 0.1k 10.1k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.1k ± 0.0k 10.0k ± 0.0k 10.0k ± 0.2k 10.0k ± 0.1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:1000]-16 281k ± 2k 280k ± 3k 279k ± 3k 280k ± 4k 279k ± 3k 280k ± 2k 280k ± 3k 279k ± 4k 278k ± 2k 282k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 282k ± 3k 282k ± 1k 281k ± 2k 280k ± 1k 282k ± 2k 283k ± 1k 281k ± 1k 280k ± 3k 282k ± 2k 283k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 288k ± 1k 289k ± 4k 284k ± 5k 286k ± 2k 288k ± 2k 284k ± 4k 288k ± 1k 288k ± 1k 289k ± 1k 287k ± 3k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.44k ± 0.15k 9.45k ± 0.13k 9.46k ± 0.15k 9.58k ± 0.03k 9.42k ± 0.06k 9.43k ± 0.17k 9.54k ± 0.06k 9.47k ± 0.15k 9.58k ± 0.21k 9.44k ± 0.20k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 180k ± 1k 179k ± 2k 178k ± 1k 179k ± 1k 177k ± 3k 179k ± 1k 178k ± 2k 180k ± 2k 179k ± 1k 180k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 184k ± 1k 184k ± 2k 182k ± 2k 185k ± 1k 183k ± 1k 182k ± 1k 183k ± 2k 185k ± 1k 184k ± 1k 184k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 186k ± 1k 186k ± 1k 185k ± 2k 186k ± 1k 186k ± 1k 186k ± 1k 186k ± 0k 187k ± 1k 185k ± 0k 187k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Sync-16 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 9.93k ± 0.14k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:1000]-16 278k ± 3k 281k ± 3k 275k ± 4k 280k ± 3k 278k ± 1k 280k ± 1k 279k ± 3k 279k ± 2k 278k ± 3k 281k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 281k ± 1k 282k ± 1k 281k ± 3k 281k ± 1k 281k ± 1k 282k ± 2k 281k ± 1k 281k ± 4k 282k ± 1k 283k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 288k ± 1k 289k ± 3k 287k ± 1k 287k ± 1k 287k ± 1k 288k ± 2k 286k ± 3k 287k ± 2k 286k ± 2k 290k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.45k ± 0.15k 9.50k ± 0.13k 9.37k ± 0.15k 9.29k ± 0.18k 9.38k ± 0.13k 9.46k ± 0.26k 9.54k ± 0.13k 9.53k ± 0.10k 9.46k ± 0.13k 9.43k ± 0.14k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 179k ± 2k 179k ± 1k 179k ± 2k 179k ± 0k 179k ± 2k 180k ± 0k 179k ± 0k 180k ± 1k 179k ± 1k 180k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 183k ± 2k 183k ± 1k 183k ± 0k 184k ± 1k 182k ± 3k 184k ± 1k 183k ± 1k 184k ± 1k 182k ± 3k 185k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 186k ± 1k 186k ± 1k 185k ± 1k 187k ± 0k 186k ± 1k 184k ± 2k 185k ± 1k 187k ± 2k 185k ± 1k 187k ± 1k

Single client Publish throughput(byte/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
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.02MB/s 2.80MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.80MB/s ± 0.04MB/s 2.79MB/s ± 0.03MB/s 2.80MB/s ± 0.01MB/s 2.79MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.78MB/s ± 0.02MB/s 2.81MB/s ± 0.03MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 2.82MB/s ± 0.03MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.02MB/s 2.80MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.02MB/s 2.80MB/s ± 0.04MB/s 2.82MB/s ± 0.02MB/s 2.83MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 2.88MB/s ± 0.01MB/s 2.89MB/s ± 0.03MB/s 2.84MB/s ± 0.05MB/s 2.86MB/s ± 0.03MB/s 2.88MB/s ± 0.03MB/s 2.84MB/s ± 0.05MB/s 2.88MB/s ± 0.01MB/s 2.88MB/s ± 0.01MB/s 2.89MB/s ± 0.01MB/s 2.88MB/s ± 0.03MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.67MB/s ± 0.16MB/s 9.67MB/s ± 0.13MB/s 9.69MB/s ± 0.15MB/s 9.81MB/s ± 0.03MB/s 9.64MB/s ± 0.07MB/s 9.66MB/s ± 0.17MB/s 9.77MB/s ± 0.06MB/s 9.70MB/s ± 0.16MB/s 9.82MB/s ± 0.21MB/s 9.67MB/s ± 0.20MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 184MB/s ± 1MB/s 183MB/s ± 2MB/s 182MB/s ± 1MB/s 184MB/s ± 1MB/s 181MB/s ± 3MB/s 183MB/s ± 1MB/s 183MB/s ± 2MB/s 184MB/s ± 2MB/s 183MB/s ± 1MB/s 184MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 189MB/s ± 1MB/s 189MB/s ± 2MB/s 187MB/s ± 2MB/s 189MB/s ± 1MB/s 188MB/s ± 1MB/s 186MB/s ± 1MB/s 187MB/s ± 2MB/s 189MB/s ± 1MB/s 188MB/s ± 1MB/s 189MB/s ± 2MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 190MB/s ± 1MB/s 190MB/s ± 1MB/s 190MB/s ± 2MB/s 190MB/s ± 1MB/s 191MB/s ± 1MB/s 190MB/s ± 1MB/s 190MB/s ± 0MB/s 191MB/s ± 1MB/s 190MB/s ± 0MB/s 191MB/s ± 2MB/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.78MB/s ± 0.04MB/s 2.81MB/s ± 0.03MB/s 2.75MB/s ± 0.04MB/s 2.80MB/s ± 0.03MB/s 2.78MB/s ± 0.01MB/s 2.80MB/s ± 0.01MB/s 2.79MB/s ± 0.02MB/s 2.79MB/s ± 0.02MB/s 2.78MB/s ± 0.03MB/s 2.81MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.03MB/s 2.81MB/s ± 0.01MB/s 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.01MB/s 2.81MB/s ± 0.04MB/s 2.82MB/s ± 0.01MB/s 2.83MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 2.88MB/s ± 0.01MB/s 2.89MB/s ± 0.03MB/s 2.87MB/s ± 0.01MB/s 2.87MB/s ± 0.01MB/s 2.87MB/s ± 0.01MB/s 2.88MB/s ± 0.03MB/s 2.86MB/s ± 0.03MB/s 2.87MB/s ± 0.02MB/s 2.86MB/s ± 0.02MB/s 2.90MB/s ± 0.01MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.67MB/s ± 0.16MB/s 9.73MB/s ± 0.13MB/s 9.59MB/s ± 0.15MB/s 9.51MB/s ± 0.19MB/s 9.60MB/s ± 0.13MB/s 9.68MB/s ± 0.27MB/s 9.76MB/s ± 0.13MB/s 9.76MB/s ± 0.11MB/s 9.69MB/s ± 0.13MB/s 9.65MB/s ± 0.14MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 183MB/s ± 2MB/s 183MB/s ± 1MB/s 183MB/s ± 2MB/s 183MB/s ± 0MB/s 183MB/s ± 2MB/s 184MB/s ± 0MB/s 183MB/s ± 0MB/s 185MB/s ± 1MB/s 183MB/s ± 1MB/s 184MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 187MB/s ± 2MB/s 188MB/s ± 1MB/s 188MB/s ± 0MB/s 188MB/s ± 1MB/s 187MB/s ± 3MB/s 188MB/s ± 1MB/s 187MB/s ± 1MB/s 189MB/s ± 1MB/s 187MB/s ± 3MB/s 189MB/s ± 2MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 191MB/s ± 1MB/s 190MB/s ± 1MB/s 189MB/s ± 1MB/s 191MB/s ± 1MB/s 190MB/s ± 1MB/s 189MB/s ± 3MB/s 187MB/s ± 3MB/s 191MB/s ± 2MB/s 190MB/s ± 1MB/s 191MB/s ± 1MB/s

Single client Publish throughput(msg/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Sync-16 10.0k ± 0.1k 10.1k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.1k ± 0.0k 10.0k ± 0.0k 10.0k ± 0.2k 10.0k ± 0.1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:1000]-16 281k ± 2k 280k ± 3k 279k ± 3k 280k ± 4k 279k ± 3k 280k ± 2k 280k ± 3k 279k ± 4k 278k ± 2k 282k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 282k ± 3k 282k ± 1k 281k ± 2k 280k ± 1k 282k ± 2k 283k ± 1k 281k ± 1k 280k ± 3k 282k ± 2k 283k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 288k ± 1k 289k ± 4k 284k ± 5k 286k ± 2k 288k ± 2k 284k ± 4k 288k ± 1k 288k ± 1k 289k ± 1k 287k ± 3k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.44k ± 0.15k 9.45k ± 0.13k 9.46k ± 0.15k 9.58k ± 0.03k 9.42k ± 0.06k 9.43k ± 0.17k 9.54k ± 0.06k 9.47k ± 0.15k 9.58k ± 0.21k 9.44k ± 0.20k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 180k ± 1k 179k ± 2k 178k ± 1k 179k ± 1k 177k ± 3k 179k ± 1k 178k ± 2k 180k ± 2k 179k ± 1k 180k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 184k ± 1k 184k ± 2k 182k ± 2k 185k ± 1k 183k ± 1k 182k ± 1k 183k ± 2k 185k ± 1k 184k ± 1k 184k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 186k ± 1k 186k ± 1k 185k ± 2k 186k ± 1k 186k ± 1k 186k ± 1k 186k ± 0k 187k ± 1k 185k ± 0k 187k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Sync-16 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 9.93k ± 0.14k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.1k 10.0k ± 0.2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:1000]-16 278k ± 3k 281k ± 3k 275k ± 4k 280k ± 3k 278k ± 1k 280k ± 1k 279k ± 3k 279k ± 2k 278k ± 3k 281k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 281k ± 1k 282k ± 1k 281k ± 3k 281k ± 1k 281k ± 1k 282k ± 2k 281k ± 1k 281k ± 4k 282k ± 1k 283k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 288k ± 1k 289k ± 3k 287k ± 1k 287k ± 1k 287k ± 1k 288k ± 2k 286k ± 3k 287k ± 2k 286k ± 2k 290k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.45k ± 0.15k 9.50k ± 0.13k 9.37k ± 0.15k 9.29k ± 0.18k 9.38k ± 0.13k 9.46k ± 0.26k 9.54k ± 0.13k 9.53k ± 0.10k 9.46k ± 0.13k 9.43k ± 0.14k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 179k ± 2k 179k ± 1k 179k ± 2k 179k ± 0k 179k ± 2k 180k ± 0k 179k ± 0k 180k ± 1k 179k ± 1k 180k ± 1k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 183k ± 2k 183k ± 1k 183k ± 0k 184k ± 1k 182k ± 3k 184k ± 1k 183k ± 1k 184k ± 1k 182k ± 3k 185k ± 2k
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 186k ± 1k 186k ± 1k 185k ± 1k 187k ± 0k 186k ± 1k 184k ± 2k 185k ± 1k 187k ± 2k 185k ± 1k 187k ± 1k

Single client Publish throughput(byte/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
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.02MB/s 2.80MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.80MB/s ± 0.04MB/s 2.79MB/s ± 0.03MB/s 2.80MB/s ± 0.01MB/s 2.79MB/s ± 0.03MB/s 2.79MB/s ± 0.03MB/s 2.78MB/s ± 0.02MB/s 2.81MB/s ± 0.03MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:4000]-16 2.82MB/s ± 0.03MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.02MB/s 2.80MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.02MB/s 2.80MB/s ± 0.04MB/s 2.82MB/s ± 0.02MB/s 2.83MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1/Async[W:8000]-16 2.88MB/s ± 0.01MB/s 2.89MB/s ± 0.03MB/s 2.84MB/s ± 0.05MB/s 2.86MB/s ± 0.03MB/s 2.88MB/s ± 0.03MB/s 2.84MB/s ± 0.05MB/s 2.88MB/s ± 0.01MB/s 2.88MB/s ± 0.01MB/s 2.89MB/s ± 0.01MB/s 2.88MB/s ± 0.03MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Sync-16 9.67MB/s ± 0.16MB/s 9.67MB/s ± 0.13MB/s 9.69MB/s ± 0.15MB/s 9.81MB/s ± 0.03MB/s 9.64MB/s ± 0.07MB/s 9.66MB/s ± 0.17MB/s 9.77MB/s ± 0.06MB/s 9.70MB/s ± 0.16MB/s 9.82MB/s ± 0.21MB/s 9.67MB/s ± 0.20MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:1000]-16 184MB/s ± 1MB/s 183MB/s ± 2MB/s 182MB/s ± 1MB/s 184MB/s ± 1MB/s 181MB/s ± 3MB/s 183MB/s ± 1MB/s 183MB/s ± 2MB/s 184MB/s ± 2MB/s 183MB/s ± 1MB/s 184MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:4000]-16 189MB/s ± 1MB/s 189MB/s ± 2MB/s 187MB/s ± 2MB/s 189MB/s ± 1MB/s 188MB/s ± 1MB/s 186MB/s ± 1MB/s 187MB/s ± 2MB/s 189MB/s ± 1MB/s 188MB/s ± 1MB/s 189MB/s ± 2MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1/Async[W:8000]-16 190MB/s ± 1MB/s 190MB/s ± 1MB/s 190MB/s ± 2MB/s 190MB/s ± 1MB/s 191MB/s ± 1MB/s 190MB/s ± 1MB/s 190MB/s ± 0MB/s 191MB/s ± 1MB/s 190MB/s ± 0MB/s 191MB/s ± 2MB/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.78MB/s ± 0.04MB/s 2.81MB/s ± 0.03MB/s 2.75MB/s ± 0.04MB/s 2.80MB/s ± 0.03MB/s 2.78MB/s ± 0.01MB/s 2.80MB/s ± 0.01MB/s 2.79MB/s ± 0.02MB/s 2.79MB/s ± 0.02MB/s 2.78MB/s ± 0.03MB/s 2.81MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:4000]-16 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.03MB/s 2.81MB/s ± 0.01MB/s 2.81MB/s ± 0.01MB/s 2.82MB/s ± 0.02MB/s 2.81MB/s ± 0.01MB/s 2.81MB/s ± 0.04MB/s 2.82MB/s ± 0.01MB/s 2.83MB/s ± 0.02MB/s
JetStreamPublish/N=3,R=3,MsgSz=10b,Subjs=1#01/Async[W:8000]-16 2.88MB/s ± 0.01MB/s 2.89MB/s ± 0.03MB/s 2.87MB/s ± 0.01MB/s 2.87MB/s ± 0.01MB/s 2.87MB/s ± 0.01MB/s 2.88MB/s ± 0.03MB/s 2.86MB/s ± 0.03MB/s 2.87MB/s ± 0.02MB/s 2.86MB/s ± 0.02MB/s 2.90MB/s ± 0.01MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Sync-16 9.67MB/s ± 0.16MB/s 9.73MB/s ± 0.13MB/s 9.59MB/s ± 0.15MB/s 9.51MB/s ± 0.19MB/s 9.60MB/s ± 0.13MB/s 9.68MB/s ± 0.27MB/s 9.76MB/s ± 0.13MB/s 9.76MB/s ± 0.11MB/s 9.69MB/s ± 0.13MB/s 9.65MB/s ± 0.14MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:1000]-16 183MB/s ± 2MB/s 183MB/s ± 1MB/s 183MB/s ± 2MB/s 183MB/s ± 0MB/s 183MB/s ± 2MB/s 184MB/s ± 0MB/s 183MB/s ± 0MB/s 185MB/s ± 1MB/s 183MB/s ± 1MB/s 184MB/s ± 1MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:4000]-16 187MB/s ± 2MB/s 188MB/s ± 1MB/s 188MB/s ± 0MB/s 188MB/s ± 1MB/s 187MB/s ± 3MB/s 188MB/s ± 1MB/s 187MB/s ± 1MB/s 189MB/s ± 1MB/s 187MB/s ± 3MB/s 189MB/s ± 2MB/s
JetStreamPublish/N=3,R=3,MsgSz=1024b,Subjs=1#01/Async[W:8000]-16 191MB/s ± 1MB/s 190MB/s ± 1MB/s 189MB/s ± 1MB/s 191MB/s ± 1MB/s 190MB/s ± 1MB/s 189MB/s ± 3MB/s 187MB/s ± 3MB/s 191MB/s ± 2MB/s 190MB/s ± 1MB/s 191MB/s ± 1MB/s

Concurrent Publish throughput (msg/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamPublishConcurrent/N=3,R=3/msgSz=10b/pubs=12-16 70.1k ± 0.3k 70.0k ± 0.1k 69.8k ± 0.2k 70.1k ± 0.1k 69.8k ± 0.2k 70.2k ± 0.2k 70.0k ± 0.2k 70.1k ± 0.1k 70.3k ± 0.1k 70.2k ± 0.2k
JetStreamPublishConcurrent/N=3,R=3/msgSz=1024b/pubs=12-16 59.9k ± 0.7k 60.1k ± 0.5k 59.0k ± 1.4k 60.1k ± 0.1k 59.9k ± 0.5k 58.6k ± 1.5k 60.0k ± 0.6k 59.6k ± 0.7k 60.6k ± 0.1k 60.0k ± 0.6k
JetStreamPublishConcurrent/N=3,R=3/msgSz=102400b/pubs=12-16 1.83k ± 0.46k 1.75k ± 0.55k 2.02k ± 0.34k 2.29k ± 0.06k 1.53k ± 0.01k 1.94k ± 0.46k 1.86k ± 0.52k 1.85k ± 0.47k 1.56k ± 0.02k 1.88k ± 0.51k
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=10b/pubs=12-16 70.0k ± 0.1k 70.0k ± 0.1k 69.8k ± 0.3k 70.0k ± 0.3k 69.8k ± 0.1k 70.1k ± 0.1k 68.1k ± 1.9k 70.1k ± 0.2k 70.2k ± 0.1k 70.1k ± 0.1k
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=1024b/pubs=12-16 60.1k ± 0.2k 60.4k ± 0.1k 60.2k ± 0.3k 60.3k ± 0.1k 59.9k ± 0.3k 59.6k ± 0.5k 60.2k ± 0.3k 60.0k ± 0.4k 59.7k ± 1.1k 60.3k ± 0.6k
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=102400b/pubs=12-16 1.72k ± 0.53k 1.57k ± 0.02k 1.84k ± 0.46k 1.97k ± 0.36k 1.55k ± 0.01k 2.06k ± 0.30k 2.17k ± 0.18k 1.72k ± 0.58k 1.88k ± 0.53k 1.54k ± 0.01k

Concurrent Publish throughput (byte/s)

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

Show results table
main [b94011e] main [5d63c16] main [e2661b5] main [48a4477] main [3e60436] main [60a276b] main [a098c7e] main [33952eb] main [395a18e] main [ed493ec]
JetStreamPublishConcurrent/N=3,R=3/msgSz=10b/pubs=12-16 700kB/s ± 0kB/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 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s
JetStreamPublishConcurrent/N=3,R=3/msgSz=1024b/pubs=12-16 61.3MB/s ± 0.7MB/s 61.6MB/s ± 0.5MB/s 60.4MB/s ± 1.4MB/s 61.5MB/s ± 0.1MB/s 61.3MB/s ± 0.6MB/s 60.0MB/s ± 1.5MB/s 61.4MB/s ± 0.6MB/s 61.0MB/s ± 0.7MB/s 62.0MB/s ± 0.1MB/s 61.4MB/s ± 0.7MB/s
JetStreamPublishConcurrent/N=3,R=3/msgSz=102400b/pubs=12-16 187MB/s ± 47MB/s 179MB/s ± 56MB/s 207MB/s ± 34MB/s 234MB/s ± 6MB/s 157MB/s ± 1MB/s 199MB/s ± 47MB/s 190MB/s ± 53MB/s 190MB/s ± 48MB/s 160MB/s ± 2MB/s 193MB/s ± 52MB/s
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=10b/pubs=12-16 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 700kB/s ± 0kB/s 680kB/s ± 20kB/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.6MB/s ± 0.2MB/s 61.8MB/s ± 0.1MB/s 61.6MB/s ± 0.3MB/s 61.7MB/s ± 0.1MB/s 61.3MB/s ± 0.3MB/s 61.1MB/s ± 0.5MB/s 61.6MB/s ± 0.3MB/s 61.5MB/s ± 0.5MB/s 61.1MB/s ± 1.1MB/s 61.7MB/s ± 0.6MB/s
JetStreamPublishConcurrent/N=3,R=3#01/msgSz=102400b/pubs=12-16 176MB/s ± 55MB/s 161MB/s ± 2MB/s 188MB/s ± 47MB/s 202MB/s ± 37MB/s 158MB/s ± 1MB/s 211MB/s ± 31MB/s 222MB/s ± 19MB/s 176MB/s ± 59MB/s 193MB/s ± 54MB/s 157MB/s ± 1MB/s