Fix Kafka configuration

etc/kapacitor/kapacitor.conf

@@ -457,13 +457,13 @@ default-retention-policy = ""
   brokers = []
   # Timeout on network operations with the brokers.
   # If 0 a default of 10s will be used.
-  timeout = 10s
+  timeout = "10s"
   # BatchSize is the number of messages that are batched before being sent to Kafka
   # If 0 a default of 100 will be used.
   batch-size = 100
   # BatchTimeout is the maximum amount of time to wait before flushing an incomplete batch.
   # If 0 a default of 1s will be used.
-  batch-timeout = 1s
+  batch-timeout = "1s"
   # Use SSL enables ssl communication.
   # Must be true for the other ssl options to take effect.
   use-ssl = false

server/config.go

@@ -150,6 +150,7 @@ func NewConfig() *Config {
 
 	c.Alerta = alerta.NewConfig()
 	c.HipChat = hipchat.NewConfig()
+	c.Kafka = kafka.Configs{kafka.NewConfig()}
 	c.MQTT = mqtt.Configs{mqtt.NewConfig()}
 	c.OpsGenie = opsgenie.NewConfig()
 	c.OpsGenie2 = opsgenie2.NewConfig()

services/kafka/config.go

@@ -44,6 +44,12 @@ type Config struct {
 	InsecureSkipVerify bool `toml:"insecure-skip-verify" override:"insecure-skip-verify"`
 }
 
+func NewConfig() Config {
+	return Config{
+		Enabled: false,
+	}
+}
+
 func (c Config) Validate() error {
 	if !c.Enabled {
 		return nil