Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ParseKafkaVersion (0.1 sec)

  1. internal/event/target/kafka.go

    			return err
    		}
    	}
    	if k.QueueDir != "" {
    		if !filepath.IsAbs(k.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    	if k.Version != "" {
    		if _, err := sarama.ParseKafkaVersion(k.Version); err != nil {
    			return err
    		}
    	}
    	if k.BatchSize > 1 {
    		if k.QueueDir == "" {
    			return errors.New("batch should be enabled only if queue dir is enabled")
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    func (h *Target) init() error {
    	if os.Getenv("_MINIO_KAFKA_DEBUG") != "" {
    		sarama.DebugLogger = log.Default()
    	}
    
    	sconfig := sarama.NewConfig()
    	if h.kconfig.Version != "" {
    		kafkaVersion, err := sarama.ParseKafkaVersion(h.kconfig.Version)
    		if err != nil {
    			return err
    		}
    		sconfig.Version = kafkaVersion
    	}
    
    	sconfig.Net.KeepAlive = 60 * time.Second
    	sconfig.Net.SASL.User = h.kconfig.SASL.User
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top