Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 24 for kafka (0.3 seconds)

  1. internal/logger/config.go

    	AuditKafka   map[string]kafka.Config `json:"audit_kafka"`
    }
    
    // NewConfig - initialize new logger config.
    func NewConfig() Config {
    	cfg := Config{
    		// Console logging is on by default
    		Console: Console{
    			Enabled: true,
    		},
    		HTTP:         make(map[string]http.Config),
    		AuditWebhook: make(map[string]http.Config),
    		AuditKafka:   make(map[string]kafka.Config),
    	}
    
    	return cfg
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.7K bytes
    - Click Count (0)
  2. cmd/config-current.go

    			Description:     "send audit logs to webhook endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.AuditKafkaSubSys,
    			Description:     "send audit logs to kafka endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyWebhookSubSys,
    			Description:     "publish bucket notifications to webhook endpoints",
    			MultipleTargets: true,
    		},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  3. internal/config/notify/parse.go

    			if err := config.CheckValidKeys(subSysTarget, kv, validKVS); err != nil {
    				return err
    			}
    		}
    	}
    	return nil
    }
    
    // DefaultKafkaKVS - default KV for kafka target
    var (
    	DefaultKafkaKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   target.KafkaTopic,
    			Value: "",
    		},
    		config.KV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  4. docs/config/README.md

    ```
    notify_webhook        publish bucket notifications to webhook endpoints
    notify_amqp           publish bucket notifications to AMQP endpoints
    notify_kafka          publish bucket notifications to Kafka endpoints
    notify_mqtt           publish bucket notifications to MQTT endpoints
    notify_nats           publish bucket notifications to NATS endpoints
    notify_nsq            publish bucket notifications to NSQ endpoints
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.1K bytes
    - Click Count (1)
  5. compat/maven-model-builder/src/test/resources/dag.txt

    	quarkus/extensions/resteasy-classic/resteasy-jackson/runtime/pom.xml
    	quarkus/extensions/smallrye-health/runtime/pom.xml
    	quarkus/extensions/kafka-client/runtime/pom.xml
    	quarkus/extensions/smallrye-reactive-messaging-kafka/runtime/pom.xml
    	quarkus/test-framework/junit5/pom.xml
    	quarkus/test-framework/kafka-companion/pom.xml
    quarkus/integration-tests/keycloak-authorization/pom.xml
    	quarkus/extensions/keycloak-authorization/runtime/pom.xml
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 224K bytes
    - Click Count (0)
  6. cmd/config-migrate.go

    	for k, args := range cfg.Notify.AMQP {
    		notify.SetNotifyAMQP(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Elasticsearch {
    		notify.SetNotifyES(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Kafka {
    		notify.SetNotifyKafka(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.MQTT {
    		notify.SetNotifyMQTT(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.MySQL {
    		notify.SetNotifyMySQL(newCfg, k, args)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  7. docs/en/docs/release-notes.md

    * Clarify function name in example in docs. PR [#1121](https://github.com/tiangolo/fastapi/pull/1121) by [@tmsick](https://github.com/tmsick).
    * Add external link [Apache Kafka producer and consumer with FastAPI and aiokafka](https://iwpnd.pw/articles/2020-03/apache-kafka-fastapi-geostream) to docs. PR [#1112](https://github.com/tiangolo/fastapi/pull/1112) by [@iwpnd](https://github.com/iwpnd).
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Apr 03 12:07:04 GMT 2026
    - 631K bytes
    - Click Count (0)
  8. docs/tr/docs/tutorial/dependencies/dependencies-in-path-operation-decorators.md

    Bu `dependencies` yaklaşımıyla, editör/araç hatalarına takılmadan dependency'lerin çalıştırılmasını sağlayabilirsiniz.
    
    Ayrıca kodunuzda kullanılmayan bir parametreyi gören yeni geliştiricilerin bunun gereksiz olduğunu düşünmesi gibi bir kafa karışıklığını da azaltabilir.
    
    ///
    
    /// info | Bilgi
    
    Bu örnekte uydurma özel header'lar olan `X-Key` ve `X-Token` kullanıyoruz.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 07:53:17 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  9. docs/tr/docs/tutorial/dependencies/classes-as-dependencies.md

    Aynı örnek şu hale gelir:
    
    {* ../../docs_src/dependencies/tutorial004_an_py310.py hl[19] *}
    
    ...ve **FastAPI** ne yapması gerektiğini bilir.
    
    /// tip | İpucu
    
    Bu size faydalı olmaktan çok kafa karıştırıcı geliyorsa, kullanmayın; buna *ihtiyacınız* yok.
    
    Bu sadece bir kısayoldur. Çünkü **FastAPI** kod tekrarını en aza indirmenize yardımcı olmayı önemser.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 13 12:41:38 GMT 2026
    - 7.3K bytes
    - Click Count (0)
  10. docs/tr/docs/features.md

    **FastAPI** ile **Pydantic**’in tüm özelliklerini elde edersiniz (FastAPI, tüm veri işlemede Pydantic’e dayanır):
    
    * **Kafa karıştırmaz**:
        * Öğrenmeniz gereken yeni bir şema tanımlama mikro-dili yok.
        * Python type’larını biliyorsanız Pydantic’i nasıl kullanacağınızı da biliyorsunuz.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 07:53:17 GMT 2026
    - 10.1K bytes
    - Click Count (0)
Back to Top