enh: override invalid parameters

taosdata · Apr 22, 2024 · 34a2148 · 34a2148
1 parent 7a84a08
commit 34a2148
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/TMQ/WebSocket/Consumer.cs b/src/TMQ/WebSocket/Consumer.cs
@@ -45,7 +45,14 @@ public Consumer(ConsumerBuilder<TValue> builder)
             _autoCommit = true;
             if (!string.IsNullOrEmpty(_options.AutoCommitIntervalMs))
             {
-                _autoCommitInterval = int.Parse(_options.AutoCommitIntervalMs);
+                try
+                {
+                    _autoCommitInterval = int.Parse(_options.AutoCommitIntervalMs);
+                }
+                catch (Exception e)
+                {
+                    throw new ArgumentException("Invalid auto commit interval", e);
+                }
             }
             else
             {