Unverified Commit d59b9d72 authored by Konstantin Korolev's avatar Konstantin Korolev Committed by GitHub
Browse files

fix: reduce NATS consumer inactive_threshold from 1h to 2min (#5861)


Signed-off-by: default avataradvpropsys <korolev.konstantin.v@gmail.com>
Co-authored-by: default avatarYan Ru Pei <yanrpei@gmail.com>
parent 7c25f702
...@@ -548,7 +548,7 @@ impl NatsQueue { ...@@ -548,7 +548,7 @@ impl NatsQueue {
if let Some(ref consumer_name) = self.consumer_name { if let Some(ref consumer_name) = self.consumer_name {
let consumer_config = jetstream::consumer::pull::Config { let consumer_config = jetstream::consumer::pull::Config {
durable_name: Some(consumer_name.clone()), durable_name: Some(consumer_name.clone()),
inactive_threshold: std::time::Duration::from_secs(3600), // 1 hour inactive_threshold: std::time::Duration::from_secs(300), // 5 minutes
..Default::default() ..Default::default()
}; };
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment