- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for batchCommitTimeout (0.31 sec)
-
internal/event/target/kafka.go
QueueLimit uint64 `json:"queueLimit"` Version string `json:"version"` BatchSize uint32 `json:"batchSize"` BatchCommitTimeout time.Duration `json:"batchCommitTimeout"` TLS struct { Enable bool `json:"enable"` RootCAs *x509.CertPool `json:"-"` SkipVerify bool `json:"skipVerify"`
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
internal/config/notify/parse.go
QueueLimit: queueLimit, Version: env.Get(versionEnv, kv.Get(target.KafkaVersion)), BatchSize: uint32(batchSize), BatchCommitTimeout: batchCommitTimeout, } tlsEnableEnv := target.EnvKafkaTLS if k != config.Default { tlsEnableEnv = tlsEnableEnv + config.Default + k } tlsSkipVerifyEnv := target.EnvKafkaTLSSkipVerify
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 47K bytes - Viewed (0)