Add fast_fail config to filebeat (#99)

streamnative · Jul 31, 2024 · 96dac9c · 96dac9c
1 parent e180e57
commit 96dac9c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/pulsar/config.go b/pulsar/config.go
@@ -73,6 +73,9 @@ type pulsarConfig struct {
 	BatchingMaxPublishDelay            time.Duration          `config:"batching_max_publish_delay"`
 	BatchingMaxMessages                uint                   `config:"batching_max_messages"`
 	MaxCacheProducers                  int                    `config:"max_cache_producers" validate:"min=1"`
+
+	// exit immediately if the connection to pulsar fails
+	FastFail bool `config:"fast_fail"`
 }
 
 func defaultConfig() pulsarConfig {
@@ -83,6 +86,7 @@ func defaultConfig() pulsarConfig {
 		BulkMaxSize:       2048,
 		MaxRetries:        3,
 		MaxCacheProducers: 8,
+		FastFail:          true,
 	}
 }
 

diff --git a/pulsar/producers.go b/pulsar/producers.go
@@ -20,6 +20,7 @@
 package pulsar
 
 import (
+	"os"
 	"sync"
 
 	"github.com/apache/pulsar-client-go/pulsar"
@@ -111,6 +112,9 @@ func (p *Producers) getOrCreateProducer(topic string, client *client) (pulsar.Pr
 		logp.Info("created pulsar producer for topic: %s", topic)
 	} else {
 		logp.Err("creating pulsar producer{topic=%s} failed: %v", topic, err)
+		if client.config.FastFail {
+			os.Exit(1)
+		}
 	}
 
 	p.lock.Unlock()