gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Consumers inherit limits for max_ack_pending and inactive_threshold from stream

Browse Source 
Signed-off-by: Neil Twigg <neil@nats.io>
This commit is contained in:
Neil Twigg
2023-04-26 10:09:29 +01:00
parent 0fadaf211f
commit 487f58f16e
7 changed files with 340 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/jetstream_cluster.go
View File

@@ -6807,7 +6807,7 @@ func (s *Server) jsClusteredConsumerRequest(ci *ClientInfo, acc *Account, subjec
}
srvLim := &s.getOpts().JetStreamLimits
// Make sure we have sane defaults
setConsumerConfigDefaults(cfg, srvLim, selectedLimits)
setConsumerConfigDefaults(cfg, &streamCfg, srvLim, selectedLimits)
if err := checkConsumerCfg(cfg, srvLim, &streamCfg, acc, selectedLimits, false); err != nil {
resp.Error = err