Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 64 for Brokers (0.04 sec)

  1. internal/logger/target/kafka/kafka.go

    	sconfig.Metadata.Retry.Backoff = (10 * time.Second)
    	sconfig.Metadata.RefreshFrequency = (15 * time.Minute)
    
    	h.config = sconfig
    
    	var brokers []string
    	for _, broker := range h.kconfig.Brokers {
    		brokers = append(brokers, broker.String())
    	}
    
    	client, err := sarama.NewClient(brokers, sconfig)
    	if err != nil {
    		return err
    	}
    
    	producer, err := sarama.NewSyncProducerFromClient(client)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  2. internal/logger/config.go

    				break
    			}
    			brokers = append(brokers, *host)
    		}
    		if err != nil {
    			return cfg, err
    		}
    
    		clientAuthCfgVal := getCfgVal(EnvKafkaTLSClientAuth, k, kv.Get(KafkaTLSClientAuth))
    		clientAuth, err := strconv.Atoi(clientAuthCfgVal)
    		if err != nil {
    			return cfg, err
    		}
    
    		kafkaArgs := kafka.Config{
    			Enabled: enabled,
    			Brokers: brokers,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  3. docs/logging/README.md

    comment          (sentence)  optionally add a comment to this setting
    ```
    
    Configure MinIO to send audit logs to locally running Kafka brokers
    
    ```
    mc admin config set myminio/ audit_kafka:target1 brokers=localhost:29092 topic=auditlog
    mc admin service restart myminio/
    ```
    
    On another terminal assuming you have `kafkacat` installed
    
    ```
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  4. internal/config/notify/parse.go

    			return nil, err
    		}
    		if !enabled {
    			continue
    		}
    		var brokers []xnet.Host
    		brokersEnv := target.EnvKafkaBrokers
    		if k != config.Default {
    			brokersEnv = brokersEnv + config.Default + k
    		}
    		kafkaBrokers := env.Get(brokersEnv, kv.Get(target.KafkaBrokers))
    		if len(kafkaBrokers) == 0 {
    			return nil, config.Errorf("kafka 'brokers' cannot be empty")
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.5K bytes
    - Viewed (0)
  5. docs/bucket/notifications/README.md

    ```
    KEY:
    notify_kafka[:name]  publish bucket notifications 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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  6. docs/es/docs/deployment/server-workers.md

    En particular, cuando corras en **Kubernetes** probablemente **no** querrás usar workers y en cambio correr **un solo proceso de Uvicorn por contenedor**, pero te contaré sobre eso más adelante en ese capítulo.
    
    ///
    
    ## Múltiples Workers { #multiple-workers }
    
    Puedes iniciar múltiples workers con la opción de línea de comando `--workers`:
    
    //// tab | `fastapi`
    
    Si usas el comando `fastapi`:
    
    <div class="termy">
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  7. docs/de/docs/deployment/server-workers.md

    ///
    
    ## Mehrere Worker { #multiple-workers }
    
    Sie können mehrere Worker mit der `--workers`-Befehlszeilenoption starten:
    
    //// tab | `fastapi`
    
    Wenn Sie den `fastapi`-Befehl verwenden:
    
    <div class="termy">
    
    ```console
    $ <font color="#4E9A06">fastapi</font> run --workers 4 <u style="text-decoration-style:solid">main.py</u>
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 02 17:32:56 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  8. docs/pt/docs/deployment/server-workers.md

    ///
    
    ## Vários trabalhadores { #multiple-workers }
    
    Você pode iniciar vários trabalhadores com a opção de linha de comando `--workers`:
    
    //// tab | `fastapi`
    
    Se você usar o comando `fastapi`:
    
    <div class="termy">
    
    ```console
    $ <font color="#4E9A06">fastapi</font> run --workers 4 <u style="text-decoration-style:solid">main.py</u>
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Nov 12 16:23:57 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  9. docs/en/docs/deployment/server-workers.md

    In particular, when running on **Kubernetes** you will probably **not** want to use workers and instead run **a single Uvicorn process per container**, but I'll tell you about it later in that chapter.
    
    ///
    
    ## Multiple Workers { #multiple-workers }
    
    You can start multiple workers with the `--workers` command line option:
    
    //// tab | `fastapi`
    
    If you use the `fastapi` command:
    
    <div class="termy">
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  10. docs/ru/docs/deployment/server-workers.md

    ///
    
    ## Несколько воркеров { #multiple-workers }
    
    Можно запустить несколько воркеров с помощью опции командной строки `--workers`:
    
    //// tab | `fastapi`
    
    Если вы используете команду `fastapi`:
    
    <div class="termy">
    
    ```console
    $ <font color="#4E9A06">fastapi</font> run --workers 4 <u style="text-decoration-style:solid">main.py</u>
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Sep 30 11:37:11 UTC 2025
    - 10.6K bytes
    - Viewed (0)
Back to top