- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 241 for broker (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/bucket/notifications/README.md
MINIO_NOTIFY_AMQP_COMMENT (sentence) optionally add a comment to this setting ```
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0) -
docs/logging/README.md
Assuming that you already have Apache Kafka configured and running. ``` mc admin config set myminio/ audit_kafka KEY: audit_kafka[:name] send audit logs to kafka endpoints ARGS: brokers* (csv) comma separated list of Kafka broker addresses topic (string) Kafka topic used for bucket notifications sasl_username (string) username for SASL/PLAIN or SASL/SCRAM authentication
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 10.5K bytes - Click Count (0) -
internal/event/target/kafka.go
config.Metadata.Retry.Backoff = (1 * time.Second) config.Metadata.RefreshFrequency = (15 * time.Minute) target.config = config brokers := []string{} for _, broker := range args.Brokers { brokers = append(brokers, broker.String()) } client, err := sarama.NewClient(brokers, config) if err != nil { if !errors.Is(err, sarama.ErrOutOfBrokers) { target.loggerOnce(context.Background(), err, target.ID().String())Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0) -
internal/logger/help.go
Optional: true, Type: "sentence", }, } HelpKafka = config.HelpKVS{ config.HelpKV{ Key: KafkaBrokers, Description: "comma separated list of Kafka broker addresses", Type: "csv", }, config.HelpKV{ Key: KafkaTopic, Description: "Kafka topic used for bucket notifications", Optional: true, Type: "string", },
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Sep 11 22:20:42 GMT 2024 - 7.4K bytes - Click Count (0) -
internal/config/notify/legacy.go
Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: target.KafkaBrokers, Value: func() string { var brokers []string for _, broker := range cfg.Brokers { brokers = append(brokers, broker.String()) } return strings.Join(brokers, config.ValueSeparator) }(), }, config.KV{ Key: target.KafkaTopic, Value: cfg.Topic, }, config.KV{Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.3K bytes - Click Count (0) -
okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list
bplaced.de bplaced.net br br.com br.it bradesco brand.se brasilia.me bremanger.no brescia.it bridgestone brindisi.it broadway broke-it.net broker broker.aero bronnoy.no bronnoysund.no brother browsersafetymark.io brumunddal.no brussels bryansk.su bryne.no brønnøy.no brønnøysund.no bs bs.it bsb.br bss.design bt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue May 27 22:00:49 GMT 2025 - 129.6K bytes - Click Count (3) -
cmd/testdata/undeleteable-object.tgz
¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ$CªPartASizes‘Ñ$C¤SizeÑ$C¥MTimeÓ É ¸Åñ€§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ d6566afb36d109141150¬content-type°application/json¡v ΄‰S ¤nullÅ , fÿ+ÛM¸" x[- Òc‰0Hûð 9Ê(#ñ´{ Dff"},{"key":"broker","value":""},{"key":"topic","value":""},{"key":"password","value":""},{"key":"username","value":""},{"key":"qos","value":"0"},{"key":"keep_alive_interval","value":"0s"},{"key":"reconnect_interval","value":"0s"},{"key":"queue_dir","value":""},{"ke...Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Click Count (0) -
okhttp/src/androidMain/assets/PublicSuffixDatabase.list
bplaced.de bplaced.net br br.com br.it bradesco brand.se brasilia.me bremanger.no brescia.it bridgestone brindisi.it broadway broke-it.net broker broker.aero bronnoy.no bronnoysund.no brother browsersafetymark.io brumunddal.no brussels bryansk.su bryne.no brønnøy.no brønnøysund.no bs bs.it bsb.br bss.design bt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Dec 31 14:50:53 GMT 2024 - 129.6K bytes - Click Count (2) -
internal/config/browser/browser.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package browser import ( "fmt" "strconv" "sync" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v3/env" ) // Browser sub-system constants const ( // browserCSPPolicy setting name for Content-Security-Policy response header value browserCSPPolicy = "csp_policy"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jun 21 00:58:58 GMT 2024 - 5.9K bytes - Click Count (0) -
docs/en/docs/css/custom.css
margin-bottom: 2em; } /* Screenshots */ /* Simulate a browser window frame. Inspired by Termynal's CSS tricks with modifications */ .screenshot { display: block; background-color: #d3e0de; border-radius: 4px; padding: 45px 5px 5px; position: relative; -webkit-box-sizing: border-box; box-sizing: border-box; } .screenshot img { display: block;
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Mon Mar 23 13:56:46 GMT 2026 - 6.6K bytes - Click Count (0)