moved samara config out of init into connect (#9051)
This commit is contained in:
parent
f26084acf1
commit
565336280a
|
|
@ -43,6 +43,7 @@ type Kafka struct {
|
||||||
|
|
||||||
Log telegraf.Logger `toml:"-"`
|
Log telegraf.Logger `toml:"-"`
|
||||||
|
|
||||||
|
saramaConfig *sarama.Config
|
||||||
producerFunc func(addrs []string, config *sarama.Config) (sarama.SyncProducer, error)
|
producerFunc func(addrs []string, config *sarama.Config) (sarama.SyncProducer, error)
|
||||||
producer sarama.SyncProducer
|
producer sarama.SyncProducer
|
||||||
|
|
||||||
|
|
@ -278,6 +279,8 @@ func (k *Kafka) Init() error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
k.saramaConfig = config
|
||||||
|
|
||||||
// Legacy support ssl config
|
// Legacy support ssl config
|
||||||
if k.Certificate != "" {
|
if k.Certificate != "" {
|
||||||
k.TLSCert = k.Certificate
|
k.TLSCert = k.Certificate
|
||||||
|
|
@ -285,15 +288,15 @@ func (k *Kafka) Init() error {
|
||||||
k.TLSKey = k.Key
|
k.TLSKey = k.Key
|
||||||
}
|
}
|
||||||
|
|
||||||
producer, err := k.producerFunc(k.Brokers, config)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
k.producer = producer
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (k *Kafka) Connect() error {
|
func (k *Kafka) Connect() error {
|
||||||
|
producer, err := k.producerFunc(k.Brokers, k.saramaConfig)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
k.producer = producer
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue