if err != nil {
				return nil, err
			}
			targets = append(targets, t)
		}
	case config.NotifyKafkaSubSys:
		kafkaTargets, err := GetNotifyKafka(cfg[config.NotifyKafkaSubSys])
		if err != nil {
			return nil, err
		}
		for id, args := range kafkaTargets {
			if !args.Enable {
				continue
			}
			args.TLS.RootCAs = transport.TLSClientConfig.RootCAs

	quitCh     chan struct{}
}

// ID - returns target ID.
func (target *KafkaTarget) ID() event.TargetID {
	return target.id
}

// Name - returns the Name of the target.
func (target *KafkaTarget) Name() string {
	return target.ID().String()
}

// Store returns any underlying store if set.
func (target *KafkaTarget) Store() event.TargetStore {
	return target.store
}